Repository: airavata-php-gateway Updated Branches: refs/heads/develop ad2035277 -> 8b67709f3
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/8b67709f/app/libraries/Airavata/Model/Data/Product/Types.php ---------------------------------------------------------------------- diff --git a/app/libraries/Airavata/Model/Data/Product/Types.php b/app/libraries/Airavata/Model/Data/Product/Types.php new file mode 100644 index 0000000..aa26196 --- /dev/null +++ b/app/libraries/Airavata/Model/Data/Product/Types.php @@ -0,0 +1,879 @@ +<?php +namespace Airavata\Model\Data\Product; + +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * 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 ReplicaLocationCategory { + const GATEWAY_DATA_STORE = 0; + const COMPUTE_RESOURCE = 1; + const LONG_TERM_STORAGE_RESOURCE = 2; + const OTHER = 3; + static public $__names = array( + 0 => 'GATEWAY_DATA_STORE', + 1 => 'COMPUTE_RESOURCE', + 2 => 'LONG_TERM_STORAGE_RESOURCE', + 3 => 'OTHER', + ); +} + +final class ReplicaPersistentType { + const TRANSIENT = 0; + const PERSISTENT = 1; + static public $__names = array( + 0 => 'TRANSIENT', + 1 => 'PERSISTENT', + ); +} + +final class DataProductType { + const DIR = 0; + const FILE = 1; + const COLLECTION = 2; + static public $__names = array( + 0 => 'DIR', + 1 => 'FILE', + 2 => 'COLLECTION', + ); +} + +class DataProductModel { + static $_TSPEC; + + /** + * @var string + */ + public $productUri = null; + /** + * @var string + */ + public $gatewayId = null; + /** + * @var string + */ + public $parentProductUri = null; + /** + * @var string + */ + public $logicalPath = null; + /** + * @var string + */ + public $productName = null; + /** + * @var string + */ + public $productDescription = null; + /** + * @var string + */ + public $ownerName = null; + /** + * @var int + */ + public $dataProductType = null; + /** + * @var int + */ + public $productSize = null; + /** + * @var int + */ + public $creationTime = null; + /** + * @var int + */ + public $lastModifiedTime = null; + /** + * @var array + */ + public $productMetadata = null; + /** + * @var \Airavata\Model\Data\Product\DataReplicaLocationModel[] + */ + public $replicaLocations = null; + /** + * @var \Airavata\Model\Data\Product\DataProductModel[] + */ + public $childProducts = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'productUri', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'gatewayId', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'parentProductUri', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'logicalPath', + 'type' => TType::STRING, + ), + 5 => array( + 'var' => 'productName', + 'type' => TType::STRING, + ), + 6 => array( + 'var' => 'productDescription', + 'type' => TType::STRING, + ), + 7 => array( + 'var' => 'ownerName', + 'type' => TType::STRING, + ), + 8 => array( + 'var' => 'dataProductType', + 'type' => TType::I32, + ), + 9 => array( + 'var' => 'productSize', + 'type' => TType::I32, + ), + 10 => array( + 'var' => 'creationTime', + 'type' => TType::I64, + ), + 11 => array( + 'var' => 'lastModifiedTime', + 'type' => TType::I64, + ), + 12 => array( + 'var' => 'productMetadata', + 'type' => TType::MAP, + 'ktype' => TType::STRING, + 'vtype' => TType::STRING, + 'key' => array( + 'type' => TType::STRING, + ), + 'val' => array( + 'type' => TType::STRING, + ), + ), + 13 => array( + 'var' => 'replicaLocations', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Data\Product\DataReplicaLocationModel', + ), + ), + 14 => array( + 'var' => 'childProducts', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Data\Product\DataProductModel', + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['productUri'])) { + $this->productUri = $vals['productUri']; + } + if (isset($vals['gatewayId'])) { + $this->gatewayId = $vals['gatewayId']; + } + if (isset($vals['parentProductUri'])) { + $this->parentProductUri = $vals['parentProductUri']; + } + if (isset($vals['logicalPath'])) { + $this->logicalPath = $vals['logicalPath']; + } + if (isset($vals['productName'])) { + $this->productName = $vals['productName']; + } + if (isset($vals['productDescription'])) { + $this->productDescription = $vals['productDescription']; + } + if (isset($vals['ownerName'])) { + $this->ownerName = $vals['ownerName']; + } + if (isset($vals['dataProductType'])) { + $this->dataProductType = $vals['dataProductType']; + } + if (isset($vals['productSize'])) { + $this->productSize = $vals['productSize']; + } + if (isset($vals['creationTime'])) { + $this->creationTime = $vals['creationTime']; + } + if (isset($vals['lastModifiedTime'])) { + $this->lastModifiedTime = $vals['lastModifiedTime']; + } + if (isset($vals['productMetadata'])) { + $this->productMetadata = $vals['productMetadata']; + } + if (isset($vals['replicaLocations'])) { + $this->replicaLocations = $vals['replicaLocations']; + } + if (isset($vals['childProducts'])) { + $this->childProducts = $vals['childProducts']; + } + } + } + + public function getName() { + return 'DataProductModel'; + } + + 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->productUri); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->gatewayId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->parentProductUri); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->logicalPath); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->productName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->productDescription); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ownerName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->dataProductType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->productSize); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->creationTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 11: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->lastModifiedTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 12: + if ($ftype == TType::MAP) { + $this->productMetadata = array(); + $_size0 = 0; + $_ktype1 = 0; + $_vtype2 = 0; + $xfer += $input->readMapBegin($_ktype1, $_vtype2, $_size0); + for ($_i4 = 0; $_i4 < $_size0; ++$_i4) + { + $key5 = ''; + $val6 = ''; + $xfer += $input->readString($key5); + $xfer += $input->readString($val6); + $this->productMetadata[$key5] = $val6; + } + $xfer += $input->readMapEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 13: + if ($ftype == TType::LST) { + $this->replicaLocations = array(); + $_size7 = 0; + $_etype10 = 0; + $xfer += $input->readListBegin($_etype10, $_size7); + for ($_i11 = 0; $_i11 < $_size7; ++$_i11) + { + $elem12 = null; + $elem12 = new \Airavata\Model\Data\Product\DataReplicaLocationModel(); + $xfer += $elem12->read($input); + $this->replicaLocations []= $elem12; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 14: + if ($ftype == TType::LST) { + $this->childProducts = array(); + $_size13 = 0; + $_etype16 = 0; + $xfer += $input->readListBegin($_etype16, $_size13); + for ($_i17 = 0; $_i17 < $_size13; ++$_i17) + { + $elem18 = null; + $elem18 = new \Airavata\Model\Data\Product\DataProductModel(); + $xfer += $elem18->read($input); + $this->childProducts []= $elem18; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('DataProductModel'); + if ($this->productUri !== null) { + $xfer += $output->writeFieldBegin('productUri', TType::STRING, 1); + $xfer += $output->writeString($this->productUri); + $xfer += $output->writeFieldEnd(); + } + if ($this->gatewayId !== null) { + $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 2); + $xfer += $output->writeString($this->gatewayId); + $xfer += $output->writeFieldEnd(); + } + if ($this->parentProductUri !== null) { + $xfer += $output->writeFieldBegin('parentProductUri', TType::STRING, 3); + $xfer += $output->writeString($this->parentProductUri); + $xfer += $output->writeFieldEnd(); + } + if ($this->logicalPath !== null) { + $xfer += $output->writeFieldBegin('logicalPath', TType::STRING, 4); + $xfer += $output->writeString($this->logicalPath); + $xfer += $output->writeFieldEnd(); + } + if ($this->productName !== null) { + $xfer += $output->writeFieldBegin('productName', TType::STRING, 5); + $xfer += $output->writeString($this->productName); + $xfer += $output->writeFieldEnd(); + } + if ($this->productDescription !== null) { + $xfer += $output->writeFieldBegin('productDescription', TType::STRING, 6); + $xfer += $output->writeString($this->productDescription); + $xfer += $output->writeFieldEnd(); + } + if ($this->ownerName !== null) { + $xfer += $output->writeFieldBegin('ownerName', TType::STRING, 7); + $xfer += $output->writeString($this->ownerName); + $xfer += $output->writeFieldEnd(); + } + if ($this->dataProductType !== null) { + $xfer += $output->writeFieldBegin('dataProductType', TType::I32, 8); + $xfer += $output->writeI32($this->dataProductType); + $xfer += $output->writeFieldEnd(); + } + if ($this->productSize !== null) { + $xfer += $output->writeFieldBegin('productSize', TType::I32, 9); + $xfer += $output->writeI32($this->productSize); + $xfer += $output->writeFieldEnd(); + } + if ($this->creationTime !== null) { + $xfer += $output->writeFieldBegin('creationTime', TType::I64, 10); + $xfer += $output->writeI64($this->creationTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->lastModifiedTime !== null) { + $xfer += $output->writeFieldBegin('lastModifiedTime', TType::I64, 11); + $xfer += $output->writeI64($this->lastModifiedTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->productMetadata !== null) { + if (!is_array($this->productMetadata)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('productMetadata', TType::MAP, 12); + { + $output->writeMapBegin(TType::STRING, TType::STRING, count($this->productMetadata)); + { + foreach ($this->productMetadata as $kiter19 => $viter20) + { + $xfer += $output->writeString($kiter19); + $xfer += $output->writeString($viter20); + } + } + $output->writeMapEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaLocations !== null) { + if (!is_array($this->replicaLocations)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('replicaLocations', TType::LST, 13); + { + $output->writeListBegin(TType::STRUCT, count($this->replicaLocations)); + { + foreach ($this->replicaLocations as $iter21) + { + $xfer += $iter21->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->childProducts !== null) { + if (!is_array($this->childProducts)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('childProducts', TType::LST, 14); + { + $output->writeListBegin(TType::STRUCT, count($this->childProducts)); + { + foreach ($this->childProducts as $iter22) + { + $xfer += $iter22->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class DataReplicaLocationModel { + static $_TSPEC; + + /** + * @var string + */ + public $replicaId = null; + /** + * @var string + */ + public $productUri = null; + /** + * @var string + */ + public $replicaName = null; + /** + * @var string + */ + public $replicaDescription = null; + /** + * @var int + */ + public $creationTime = null; + /** + * @var int + */ + public $lastModifiedTime = null; + /** + * @var int + */ + public $validUntilTime = null; + /** + * @var int + */ + public $replicaLocationCategory = null; + /** + * @var int + */ + public $replicaPersistentType = null; + /** + * @var string + */ + public $storageResourceId = null; + /** + * @var string + */ + public $filePath = null; + /** + * @var array + */ + public $replicaMetadata = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'replicaId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'productUri', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'replicaName', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'replicaDescription', + 'type' => TType::STRING, + ), + 5 => array( + 'var' => 'creationTime', + 'type' => TType::I64, + ), + 6 => array( + 'var' => 'lastModifiedTime', + 'type' => TType::I64, + ), + 7 => array( + 'var' => 'validUntilTime', + 'type' => TType::I64, + ), + 8 => array( + 'var' => 'replicaLocationCategory', + 'type' => TType::I32, + ), + 9 => array( + 'var' => 'replicaPersistentType', + 'type' => TType::I32, + ), + 10 => array( + 'var' => 'storageResourceId', + 'type' => TType::STRING, + ), + 11 => array( + 'var' => 'filePath', + 'type' => TType::STRING, + ), + 12 => array( + 'var' => 'replicaMetadata', + 'type' => TType::MAP, + 'ktype' => TType::STRING, + 'vtype' => TType::STRING, + 'key' => array( + 'type' => TType::STRING, + ), + 'val' => array( + 'type' => TType::STRING, + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['replicaId'])) { + $this->replicaId = $vals['replicaId']; + } + if (isset($vals['productUri'])) { + $this->productUri = $vals['productUri']; + } + if (isset($vals['replicaName'])) { + $this->replicaName = $vals['replicaName']; + } + if (isset($vals['replicaDescription'])) { + $this->replicaDescription = $vals['replicaDescription']; + } + if (isset($vals['creationTime'])) { + $this->creationTime = $vals['creationTime']; + } + if (isset($vals['lastModifiedTime'])) { + $this->lastModifiedTime = $vals['lastModifiedTime']; + } + if (isset($vals['validUntilTime'])) { + $this->validUntilTime = $vals['validUntilTime']; + } + if (isset($vals['replicaLocationCategory'])) { + $this->replicaLocationCategory = $vals['replicaLocationCategory']; + } + if (isset($vals['replicaPersistentType'])) { + $this->replicaPersistentType = $vals['replicaPersistentType']; + } + if (isset($vals['storageResourceId'])) { + $this->storageResourceId = $vals['storageResourceId']; + } + if (isset($vals['filePath'])) { + $this->filePath = $vals['filePath']; + } + if (isset($vals['replicaMetadata'])) { + $this->replicaMetadata = $vals['replicaMetadata']; + } + } + } + + public function getName() { + return 'DataReplicaLocationModel'; + } + + 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->replicaId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->productUri); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->replicaName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->replicaDescription); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->creationTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->lastModifiedTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->validUntilTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->replicaLocationCategory); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->replicaPersistentType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->storageResourceId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 11: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->filePath); + } else { + $xfer += $input->skip($ftype); + } + break; + case 12: + if ($ftype == TType::MAP) { + $this->replicaMetadata = array(); + $_size23 = 0; + $_ktype24 = 0; + $_vtype25 = 0; + $xfer += $input->readMapBegin($_ktype24, $_vtype25, $_size23); + for ($_i27 = 0; $_i27 < $_size23; ++$_i27) + { + $key28 = ''; + $val29 = ''; + $xfer += $input->readString($key28); + $xfer += $input->readString($val29); + $this->replicaMetadata[$key28] = $val29; + } + $xfer += $input->readMapEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('DataReplicaLocationModel'); + if ($this->replicaId !== null) { + $xfer += $output->writeFieldBegin('replicaId', TType::STRING, 1); + $xfer += $output->writeString($this->replicaId); + $xfer += $output->writeFieldEnd(); + } + if ($this->productUri !== null) { + $xfer += $output->writeFieldBegin('productUri', TType::STRING, 2); + $xfer += $output->writeString($this->productUri); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaName !== null) { + $xfer += $output->writeFieldBegin('replicaName', TType::STRING, 3); + $xfer += $output->writeString($this->replicaName); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaDescription !== null) { + $xfer += $output->writeFieldBegin('replicaDescription', TType::STRING, 4); + $xfer += $output->writeString($this->replicaDescription); + $xfer += $output->writeFieldEnd(); + } + if ($this->creationTime !== null) { + $xfer += $output->writeFieldBegin('creationTime', TType::I64, 5); + $xfer += $output->writeI64($this->creationTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->lastModifiedTime !== null) { + $xfer += $output->writeFieldBegin('lastModifiedTime', TType::I64, 6); + $xfer += $output->writeI64($this->lastModifiedTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->validUntilTime !== null) { + $xfer += $output->writeFieldBegin('validUntilTime', TType::I64, 7); + $xfer += $output->writeI64($this->validUntilTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaLocationCategory !== null) { + $xfer += $output->writeFieldBegin('replicaLocationCategory', TType::I32, 8); + $xfer += $output->writeI32($this->replicaLocationCategory); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaPersistentType !== null) { + $xfer += $output->writeFieldBegin('replicaPersistentType', TType::I32, 9); + $xfer += $output->writeI32($this->replicaPersistentType); + $xfer += $output->writeFieldEnd(); + } + if ($this->storageResourceId !== null) { + $xfer += $output->writeFieldBegin('storageResourceId', TType::STRING, 10); + $xfer += $output->writeString($this->storageResourceId); + $xfer += $output->writeFieldEnd(); + } + if ($this->filePath !== null) { + $xfer += $output->writeFieldBegin('filePath', TType::STRING, 11); + $xfer += $output->writeString($this->filePath); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaMetadata !== null) { + if (!is_array($this->replicaMetadata)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('replicaMetadata', TType::MAP, 12); + { + $output->writeMapBegin(TType::STRING, TType::STRING, count($this->replicaMetadata)); + { + foreach ($this->replicaMetadata as $kiter30 => $viter31) + { + $xfer += $output->writeString($kiter30); + $xfer += $output->writeString($viter31); + } + } + $output->writeMapEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + + http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/8b67709f/app/libraries/Airavata/Model/Data/Resource/Types.php ---------------------------------------------------------------------- diff --git a/app/libraries/Airavata/Model/Data/Resource/Types.php b/app/libraries/Airavata/Model/Data/Resource/Types.php new file mode 100644 index 0000000..cd5542a --- /dev/null +++ b/app/libraries/Airavata/Model/Data/Resource/Types.php @@ -0,0 +1,854 @@ +<?php +namespace Airavata\Model\Data\Resource; + +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * 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 ReplicaLocationCategory { + const GATEWAY_DATA_STORE = 0; + const COMPUTE_RESOURCE = 1; + const LONG_TERM_STORAGE_RESOURCE = 2; + const OTHER = 3; + static public $__names = array( + 0 => 'GATEWAY_DATA_STORE', + 1 => 'COMPUTE_RESOURCE', + 2 => 'LONG_TERM_STORAGE_RESOURCE', + 3 => 'OTHER', + ); +} + +final class ReplicaPersistentType { + const TRANSIENT = 0; + const PERSISTENT = 1; + static public $__names = array( + 0 => 'TRANSIENT', + 1 => 'PERSISTENT', + ); +} + +final class DataResourceType { + const COLLECTION = 0; + const FILE = 1; + static public $__names = array( + 0 => 'COLLECTION', + 1 => 'FILE', + ); +} + +class DataResourceModel { + static $_TSPEC; + + /** + * @var string + */ + public $resourceId = null; + /** + * @var string + */ + public $gatewayId = null; + /** + * @var string + */ + public $parentResourceId = null; + /** + * @var string + */ + public $resourceName = null; + /** + * @var string + */ + public $resourceDescription = null; + /** + * @var string + */ + public $ownerName = null; + /** + * @var int + */ + public $dataResourceType = null; + /** + * @var int + */ + public $resourceSize = null; + /** + * @var int + */ + public $creationTime = null; + /** + * @var int + */ + public $lastModifiedTime = null; + /** + * @var array + */ + public $resourceMetadata = null; + /** + * @var \Airavata\Model\Data\Resource\DataReplicaLocationModel[] + */ + public $replicaLocations = null; + /** + * @var \Airavata\Model\Data\Resource\DataResourceModel[] + */ + public $childResources = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'resourceId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'gatewayId', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'parentResourceId', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'resourceName', + 'type' => TType::STRING, + ), + 5 => array( + 'var' => 'resourceDescription', + 'type' => TType::STRING, + ), + 6 => array( + 'var' => 'ownerName', + 'type' => TType::STRING, + ), + 7 => array( + 'var' => 'dataResourceType', + 'type' => TType::I32, + ), + 8 => array( + 'var' => 'resourceSize', + 'type' => TType::I32, + ), + 9 => array( + 'var' => 'creationTime', + 'type' => TType::I64, + ), + 10 => array( + 'var' => 'lastModifiedTime', + 'type' => TType::I64, + ), + 11 => array( + 'var' => 'resourceMetadata', + 'type' => TType::MAP, + 'ktype' => TType::STRING, + 'vtype' => TType::STRING, + 'key' => array( + 'type' => TType::STRING, + ), + 'val' => array( + 'type' => TType::STRING, + ), + ), + 12 => array( + 'var' => 'replicaLocations', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Data\Resource\DataReplicaLocationModel', + ), + ), + 13 => array( + 'var' => 'childResources', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Data\Resource\DataResourceModel', + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['resourceId'])) { + $this->resourceId = $vals['resourceId']; + } + if (isset($vals['gatewayId'])) { + $this->gatewayId = $vals['gatewayId']; + } + if (isset($vals['parentResourceId'])) { + $this->parentResourceId = $vals['parentResourceId']; + } + if (isset($vals['resourceName'])) { + $this->resourceName = $vals['resourceName']; + } + if (isset($vals['resourceDescription'])) { + $this->resourceDescription = $vals['resourceDescription']; + } + if (isset($vals['ownerName'])) { + $this->ownerName = $vals['ownerName']; + } + if (isset($vals['dataResourceType'])) { + $this->dataResourceType = $vals['dataResourceType']; + } + if (isset($vals['resourceSize'])) { + $this->resourceSize = $vals['resourceSize']; + } + if (isset($vals['creationTime'])) { + $this->creationTime = $vals['creationTime']; + } + if (isset($vals['lastModifiedTime'])) { + $this->lastModifiedTime = $vals['lastModifiedTime']; + } + if (isset($vals['resourceMetadata'])) { + $this->resourceMetadata = $vals['resourceMetadata']; + } + if (isset($vals['replicaLocations'])) { + $this->replicaLocations = $vals['replicaLocations']; + } + if (isset($vals['childResources'])) { + $this->childResources = $vals['childResources']; + } + } + } + + public function getName() { + return 'DataResourceModel'; + } + + 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->resourceId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->gatewayId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->parentResourceId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->resourceName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->resourceDescription); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ownerName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->dataResourceType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->resourceSize); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->creationTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->lastModifiedTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 11: + if ($ftype == TType::MAP) { + $this->resourceMetadata = array(); + $_size0 = 0; + $_ktype1 = 0; + $_vtype2 = 0; + $xfer += $input->readMapBegin($_ktype1, $_vtype2, $_size0); + for ($_i4 = 0; $_i4 < $_size0; ++$_i4) + { + $key5 = ''; + $val6 = ''; + $xfer += $input->readString($key5); + $xfer += $input->readString($val6); + $this->resourceMetadata[$key5] = $val6; + } + $xfer += $input->readMapEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 12: + if ($ftype == TType::LST) { + $this->replicaLocations = array(); + $_size7 = 0; + $_etype10 = 0; + $xfer += $input->readListBegin($_etype10, $_size7); + for ($_i11 = 0; $_i11 < $_size7; ++$_i11) + { + $elem12 = null; + $elem12 = new \Airavata\Model\Data\Resource\DataReplicaLocationModel(); + $xfer += $elem12->read($input); + $this->replicaLocations []= $elem12; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 13: + if ($ftype == TType::LST) { + $this->childResources = array(); + $_size13 = 0; + $_etype16 = 0; + $xfer += $input->readListBegin($_etype16, $_size13); + for ($_i17 = 0; $_i17 < $_size13; ++$_i17) + { + $elem18 = null; + $elem18 = new \Airavata\Model\Data\Resource\DataResourceModel(); + $xfer += $elem18->read($input); + $this->childResources []= $elem18; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('DataResourceModel'); + if ($this->resourceId !== null) { + $xfer += $output->writeFieldBegin('resourceId', TType::STRING, 1); + $xfer += $output->writeString($this->resourceId); + $xfer += $output->writeFieldEnd(); + } + if ($this->gatewayId !== null) { + $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 2); + $xfer += $output->writeString($this->gatewayId); + $xfer += $output->writeFieldEnd(); + } + if ($this->parentResourceId !== null) { + $xfer += $output->writeFieldBegin('parentResourceId', TType::STRING, 3); + $xfer += $output->writeString($this->parentResourceId); + $xfer += $output->writeFieldEnd(); + } + if ($this->resourceName !== null) { + $xfer += $output->writeFieldBegin('resourceName', TType::STRING, 4); + $xfer += $output->writeString($this->resourceName); + $xfer += $output->writeFieldEnd(); + } + if ($this->resourceDescription !== null) { + $xfer += $output->writeFieldBegin('resourceDescription', TType::STRING, 5); + $xfer += $output->writeString($this->resourceDescription); + $xfer += $output->writeFieldEnd(); + } + if ($this->ownerName !== null) { + $xfer += $output->writeFieldBegin('ownerName', TType::STRING, 6); + $xfer += $output->writeString($this->ownerName); + $xfer += $output->writeFieldEnd(); + } + if ($this->dataResourceType !== null) { + $xfer += $output->writeFieldBegin('dataResourceType', TType::I32, 7); + $xfer += $output->writeI32($this->dataResourceType); + $xfer += $output->writeFieldEnd(); + } + if ($this->resourceSize !== null) { + $xfer += $output->writeFieldBegin('resourceSize', TType::I32, 8); + $xfer += $output->writeI32($this->resourceSize); + $xfer += $output->writeFieldEnd(); + } + if ($this->creationTime !== null) { + $xfer += $output->writeFieldBegin('creationTime', TType::I64, 9); + $xfer += $output->writeI64($this->creationTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->lastModifiedTime !== null) { + $xfer += $output->writeFieldBegin('lastModifiedTime', TType::I64, 10); + $xfer += $output->writeI64($this->lastModifiedTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->resourceMetadata !== null) { + if (!is_array($this->resourceMetadata)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('resourceMetadata', TType::MAP, 11); + { + $output->writeMapBegin(TType::STRING, TType::STRING, count($this->resourceMetadata)); + { + foreach ($this->resourceMetadata as $kiter19 => $viter20) + { + $xfer += $output->writeString($kiter19); + $xfer += $output->writeString($viter20); + } + } + $output->writeMapEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaLocations !== null) { + if (!is_array($this->replicaLocations)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('replicaLocations', TType::LST, 12); + { + $output->writeListBegin(TType::STRUCT, count($this->replicaLocations)); + { + foreach ($this->replicaLocations as $iter21) + { + $xfer += $iter21->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->childResources !== null) { + if (!is_array($this->childResources)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('childResources', TType::LST, 13); + { + $output->writeListBegin(TType::STRUCT, count($this->childResources)); + { + foreach ($this->childResources as $iter22) + { + $xfer += $iter22->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class DataReplicaLocationModel { + static $_TSPEC; + + /** + * @var string + */ + public $replicaId = null; + /** + * @var string + */ + public $resourceId = null; + /** + * @var string + */ + public $replicaName = null; + /** + * @var string + */ + public $replicaDescription = null; + /** + * @var int + */ + public $creationTime = null; + /** + * @var int + */ + public $lastModifiedTime = null; + /** + * @var int + */ + public $validUntilTime = null; + /** + * @var int + */ + public $replicaLocationCategory = null; + /** + * @var int + */ + public $replicaPersistentType = null; + /** + * @var string + */ + public $storageResourceId = null; + /** + * @var string + */ + public $fileAbsolutePath = null; + /** + * @var array + */ + public $replicaMetadata = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'replicaId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'resourceId', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'replicaName', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'replicaDescription', + 'type' => TType::STRING, + ), + 5 => array( + 'var' => 'creationTime', + 'type' => TType::I64, + ), + 6 => array( + 'var' => 'lastModifiedTime', + 'type' => TType::I64, + ), + 7 => array( + 'var' => 'validUntilTime', + 'type' => TType::I64, + ), + 8 => array( + 'var' => 'replicaLocationCategory', + 'type' => TType::I32, + ), + 9 => array( + 'var' => 'replicaPersistentType', + 'type' => TType::I32, + ), + 10 => array( + 'var' => 'storageResourceId', + 'type' => TType::STRING, + ), + 11 => array( + 'var' => 'fileAbsolutePath', + 'type' => TType::STRING, + ), + 12 => array( + 'var' => 'replicaMetadata', + 'type' => TType::MAP, + 'ktype' => TType::STRING, + 'vtype' => TType::STRING, + 'key' => array( + 'type' => TType::STRING, + ), + 'val' => array( + 'type' => TType::STRING, + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['replicaId'])) { + $this->replicaId = $vals['replicaId']; + } + if (isset($vals['resourceId'])) { + $this->resourceId = $vals['resourceId']; + } + if (isset($vals['replicaName'])) { + $this->replicaName = $vals['replicaName']; + } + if (isset($vals['replicaDescription'])) { + $this->replicaDescription = $vals['replicaDescription']; + } + if (isset($vals['creationTime'])) { + $this->creationTime = $vals['creationTime']; + } + if (isset($vals['lastModifiedTime'])) { + $this->lastModifiedTime = $vals['lastModifiedTime']; + } + if (isset($vals['validUntilTime'])) { + $this->validUntilTime = $vals['validUntilTime']; + } + if (isset($vals['replicaLocationCategory'])) { + $this->replicaLocationCategory = $vals['replicaLocationCategory']; + } + if (isset($vals['replicaPersistentType'])) { + $this->replicaPersistentType = $vals['replicaPersistentType']; + } + if (isset($vals['storageResourceId'])) { + $this->storageResourceId = $vals['storageResourceId']; + } + if (isset($vals['fileAbsolutePath'])) { + $this->fileAbsolutePath = $vals['fileAbsolutePath']; + } + if (isset($vals['replicaMetadata'])) { + $this->replicaMetadata = $vals['replicaMetadata']; + } + } + } + + public function getName() { + return 'DataReplicaLocationModel'; + } + + 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->replicaId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->resourceId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->replicaName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->replicaDescription); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->creationTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->lastModifiedTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->validUntilTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->replicaLocationCategory); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->replicaPersistentType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->storageResourceId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 11: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->fileAbsolutePath); + } else { + $xfer += $input->skip($ftype); + } + break; + case 12: + if ($ftype == TType::MAP) { + $this->replicaMetadata = array(); + $_size23 = 0; + $_ktype24 = 0; + $_vtype25 = 0; + $xfer += $input->readMapBegin($_ktype24, $_vtype25, $_size23); + for ($_i27 = 0; $_i27 < $_size23; ++$_i27) + { + $key28 = ''; + $val29 = ''; + $xfer += $input->readString($key28); + $xfer += $input->readString($val29); + $this->replicaMetadata[$key28] = $val29; + } + $xfer += $input->readMapEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('DataReplicaLocationModel'); + if ($this->replicaId !== null) { + $xfer += $output->writeFieldBegin('replicaId', TType::STRING, 1); + $xfer += $output->writeString($this->replicaId); + $xfer += $output->writeFieldEnd(); + } + if ($this->resourceId !== null) { + $xfer += $output->writeFieldBegin('resourceId', TType::STRING, 2); + $xfer += $output->writeString($this->resourceId); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaName !== null) { + $xfer += $output->writeFieldBegin('replicaName', TType::STRING, 3); + $xfer += $output->writeString($this->replicaName); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaDescription !== null) { + $xfer += $output->writeFieldBegin('replicaDescription', TType::STRING, 4); + $xfer += $output->writeString($this->replicaDescription); + $xfer += $output->writeFieldEnd(); + } + if ($this->creationTime !== null) { + $xfer += $output->writeFieldBegin('creationTime', TType::I64, 5); + $xfer += $output->writeI64($this->creationTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->lastModifiedTime !== null) { + $xfer += $output->writeFieldBegin('lastModifiedTime', TType::I64, 6); + $xfer += $output->writeI64($this->lastModifiedTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->validUntilTime !== null) { + $xfer += $output->writeFieldBegin('validUntilTime', TType::I64, 7); + $xfer += $output->writeI64($this->validUntilTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaLocationCategory !== null) { + $xfer += $output->writeFieldBegin('replicaLocationCategory', TType::I32, 8); + $xfer += $output->writeI32($this->replicaLocationCategory); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaPersistentType !== null) { + $xfer += $output->writeFieldBegin('replicaPersistentType', TType::I32, 9); + $xfer += $output->writeI32($this->replicaPersistentType); + $xfer += $output->writeFieldEnd(); + } + if ($this->storageResourceId !== null) { + $xfer += $output->writeFieldBegin('storageResourceId', TType::STRING, 10); + $xfer += $output->writeString($this->storageResourceId); + $xfer += $output->writeFieldEnd(); + } + if ($this->fileAbsolutePath !== null) { + $xfer += $output->writeFieldBegin('fileAbsolutePath', TType::STRING, 11); + $xfer += $output->writeString($this->fileAbsolutePath); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaMetadata !== null) { + if (!is_array($this->replicaMetadata)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('replicaMetadata', TType::MAP, 12); + { + $output->writeMapBegin(TType::STRING, TType::STRING, count($this->replicaMetadata)); + { + foreach ($this->replicaMetadata as $kiter30 => $viter31) + { + $xfer += $output->writeString($kiter30); + $xfer += $output->writeString($viter31); + } + } + $output->writeMapEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + + http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/8b67709f/app/libraries/Airavata/Model/Process/Types.php ---------------------------------------------------------------------- diff --git a/app/libraries/Airavata/Model/Process/Types.php b/app/libraries/Airavata/Model/Process/Types.php index c0000d0..179be2b 100644 --- a/app/libraries/Airavata/Model/Process/Types.php +++ b/app/libraries/Airavata/Model/Process/Types.php @@ -117,6 +117,10 @@ class ProcessModel { * @var string */ public $experimentDataDir = null; + /** + * @var string + */ + public $userName = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -231,6 +235,10 @@ class ProcessModel { 'var' => 'experimentDataDir', 'type' => TType::STRING, ), + 23 => array( + 'var' => 'userName', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -300,6 +308,9 @@ class ProcessModel { if (isset($vals['experimentDataDir'])) { $this->experimentDataDir = $vals['experimentDataDir']; } + if (isset($vals['userName'])) { + $this->userName = $vals['userName']; + } } } @@ -522,6 +533,13 @@ class ProcessModel { $xfer += $input->skip($ftype); } break; + case 23: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->userName); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -702,6 +720,11 @@ class ProcessModel { $xfer += $output->writeString($this->experimentDataDir); $xfer += $output->writeFieldEnd(); } + if ($this->userName !== null) { + $xfer += $output->writeFieldBegin('userName', TType::STRING, 23); + $xfer += $output->writeString($this->userName); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/8b67709f/app/libraries/Airavata/Model/Scheduling/Types.php ---------------------------------------------------------------------- diff --git a/app/libraries/Airavata/Model/Scheduling/Types.php b/app/libraries/Airavata/Model/Scheduling/Types.php index 44c1180..9eb8ebb 100644 --- a/app/libraries/Airavata/Model/Scheduling/Types.php +++ b/app/libraries/Airavata/Model/Scheduling/Types.php @@ -61,6 +61,18 @@ class ComputationalResourceSchedulingModel { * @var string */ public $staticWorkingDir = null; + /** + * @var string + */ + public $overrideLoginUserName = null; + /** + * @var string + */ + public $overrideScratchLocation = null; + /** + * @var string + */ + public $overrideAllocationProjectNumber = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -101,6 +113,18 @@ class ComputationalResourceSchedulingModel { 'var' => 'staticWorkingDir', 'type' => TType::STRING, ), + 10 => array( + 'var' => 'overrideLoginUserName', + 'type' => TType::STRING, + ), + 11 => array( + 'var' => 'overrideScratchLocation', + 'type' => TType::STRING, + ), + 12 => array( + 'var' => 'overrideAllocationProjectNumber', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -131,6 +155,15 @@ class ComputationalResourceSchedulingModel { if (isset($vals['staticWorkingDir'])) { $this->staticWorkingDir = $vals['staticWorkingDir']; } + if (isset($vals['overrideLoginUserName'])) { + $this->overrideLoginUserName = $vals['overrideLoginUserName']; + } + if (isset($vals['overrideScratchLocation'])) { + $this->overrideScratchLocation = $vals['overrideScratchLocation']; + } + if (isset($vals['overrideAllocationProjectNumber'])) { + $this->overrideAllocationProjectNumber = $vals['overrideAllocationProjectNumber']; + } } } @@ -216,6 +249,27 @@ class ComputationalResourceSchedulingModel { $xfer += $input->skip($ftype); } break; + case 10: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->overrideLoginUserName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 11: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->overrideScratchLocation); + } else { + $xfer += $input->skip($ftype); + } + break; + case 12: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->overrideAllocationProjectNumber); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -274,6 +328,21 @@ class ComputationalResourceSchedulingModel { $xfer += $output->writeString($this->staticWorkingDir); $xfer += $output->writeFieldEnd(); } + if ($this->overrideLoginUserName !== null) { + $xfer += $output->writeFieldBegin('overrideLoginUserName', TType::STRING, 10); + $xfer += $output->writeString($this->overrideLoginUserName); + $xfer += $output->writeFieldEnd(); + } + if ($this->overrideScratchLocation !== null) { + $xfer += $output->writeFieldBegin('overrideScratchLocation', TType::STRING, 11); + $xfer += $output->writeString($this->overrideScratchLocation); + $xfer += $output->writeFieldEnd(); + } + if ($this->overrideAllocationProjectNumber !== null) { + $xfer += $output->writeFieldBegin('overrideAllocationProjectNumber', TType::STRING, 12); + $xfer += $output->writeString($this->overrideAllocationProjectNumber); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/8b67709f/app/libraries/Airavata/Model/Workspace/Types.php ---------------------------------------------------------------------- diff --git a/app/libraries/Airavata/Model/Workspace/Types.php b/app/libraries/Airavata/Model/Workspace/Types.php index 6903330..cb7b721 100644 --- a/app/libraries/Airavata/Model/Workspace/Types.php +++ b/app/libraries/Airavata/Model/Workspace/Types.php @@ -650,4 +650,194 @@ class Gateway { } +class Notification { + static $_TSPEC; + + /** + * @var string + */ + public $notificationId = null; + /** + * @var string + */ + public $gatewayId = null; + /** + * @var string + */ + public $title = null; + /** + * @var string + */ + public $notifcationMessage = null; + /** + * @var int + */ + public $publishedtime = null; + /** + * @var int + */ + public $expirationTime = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'notificationId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'gatewayId', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'title', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'notifcationMessage', + 'type' => TType::STRING, + ), + 5 => array( + 'var' => 'publishedtime', + 'type' => TType::I64, + ), + 6 => array( + 'var' => 'expirationTime', + 'type' => TType::I64, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['notificationId'])) { + $this->notificationId = $vals['notificationId']; + } + if (isset($vals['gatewayId'])) { + $this->gatewayId = $vals['gatewayId']; + } + if (isset($vals['title'])) { + $this->title = $vals['title']; + } + if (isset($vals['notifcationMessage'])) { + $this->notifcationMessage = $vals['notifcationMessage']; + } + if (isset($vals['publishedtime'])) { + $this->publishedtime = $vals['publishedtime']; + } + if (isset($vals['expirationTime'])) { + $this->expirationTime = $vals['expirationTime']; + } + } + } + + public function getName() { + return 'Notification'; + } + + 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->notificationId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->gatewayId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->title); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->notifcationMessage); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->publishedtime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->expirationTime); + } 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('Notification'); + if ($this->notificationId !== null) { + $xfer += $output->writeFieldBegin('notificationId', TType::STRING, 1); + $xfer += $output->writeString($this->notificationId); + $xfer += $output->writeFieldEnd(); + } + if ($this->gatewayId !== null) { + $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 2); + $xfer += $output->writeString($this->gatewayId); + $xfer += $output->writeFieldEnd(); + } + if ($this->title !== null) { + $xfer += $output->writeFieldBegin('title', TType::STRING, 3); + $xfer += $output->writeString($this->title); + $xfer += $output->writeFieldEnd(); + } + if ($this->notifcationMessage !== null) { + $xfer += $output->writeFieldBegin('notifcationMessage', TType::STRING, 4); + $xfer += $output->writeString($this->notifcationMessage); + $xfer += $output->writeFieldEnd(); + } + if ($this->publishedtime !== null) { + $xfer += $output->writeFieldBegin('publishedtime', TType::I64, 5); + $xfer += $output->writeI64($this->publishedtime); + $xfer += $output->writeFieldEnd(); + } + if ($this->expirationTime !== null) { + $xfer += $output->writeFieldBegin('expirationTime', TType::I64, 6); + $xfer += $output->writeI64($this->expirationTime); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} +
