Return-Path: X-Original-To: apmail-airavata-commits-archive@www.apache.org Delivered-To: apmail-airavata-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 23C3D18BBC for ; Wed, 23 Dec 2015 17:59:52 +0000 (UTC) Received: (qmail 42295 invoked by uid 500); 23 Dec 2015 17:59:52 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 42139 invoked by uid 500); 23 Dec 2015 17:59:51 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 40782 invoked by uid 99); 23 Dec 2015 17:59:51 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 23 Dec 2015 17:59:51 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 17FDBE0B2D; Wed, 23 Dec 2015 17:59:51 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: scnakandala@apache.org To: commits@airavata.apache.org Date: Wed, 23 Dec 2015 18:00:09 -0000 Message-Id: In-Reply-To: <75f5d6ab93c04a7d87c9bb34d0aee022@git.apache.org> References: <75f5d6ab93c04a7d87c9bb34d0aee022@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [20/24] airavata git commit: adding mongo base matadata catalog and replica catalog http://git-wip-us.apache.org/repos/asf/airavata/blob/b61cfcd3/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Types.php deleted file mode 100644 index 4734e54..0000000 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Types.php +++ /dev/null @@ -1,795 +0,0 @@ - 'SCP', - 1 => 'SFTP', - 2 => 'HTTP', - 3 => 'HTTPS', - 4 => 'GridFTP', - 5 => 'LOCAL', - ); -} - -final class FileNodeTypes { - const DIRECTORY = 0; - const FILE = 1; - static public $__names = array( - 0 => 'DIRECTORY', - 1 => 'FILE', - ); -} - -final class FileTransferMode { - const SYNC = 0; - const ASYNC = 1; - static public $__names = array( - 0 => 'SYNC', - 1 => 'ASYNC', - ); -} - -final class FileTransferStatus { - const CREATED = 0; - const QUEUED = 1; - const RUNNING = 2; - const COMPLETED = 3; - const FAILED = 4; - static public $__names = array( - 0 => 'CREATED', - 1 => 'QUEUED', - 2 => 'RUNNING', - 3 => 'COMPLETED', - 4 => 'FAILED', - ); -} - -class FileTransferRequest { - static $_TSPEC; - - /** - * @var string - */ - public $transferId = null; - /** - * @var string - */ - public $srcHostname = null; - /** - * @var string - */ - public $srcLoginName = null; - /** - * @var int - */ - public $srcPort = null; - /** - * @var int - */ - public $srcProtocol = null; - /** - * @var string - */ - public $srcFilePath = null; - /** - * @var string - */ - public $srcHostCredToken = null; - /** - * @var string - */ - public $destHostname = null; - /** - * @var string - */ - public $destLoginName = null; - /** - * @var int - */ - public $destPort = null; - /** - * @var int - */ - public $destProtocol = null; - /** - * @var string - */ - public $destFilePath = null; - /** - * @var string - */ - public $destHostCredToken = null; - /** - * @var int - */ - public $fileTransferMode = null; - /** - * @var int - */ - public $transferStatus = null; - /** - * @var int - */ - public $fileSize = null; - /** - * @var int - */ - public $transferTime = null; - /** - * @var int - */ - public $createdTime = null; - /** - * @var int - */ - public $lastModifiedType = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'transferId', - 'type' => TType::STRING, - ), - 2 => array( - 'var' => 'srcHostname', - 'type' => TType::STRING, - ), - 3 => array( - 'var' => 'srcLoginName', - 'type' => TType::STRING, - ), - 4 => array( - 'var' => 'srcPort', - 'type' => TType::I64, - ), - 5 => array( - 'var' => 'srcProtocol', - 'type' => TType::I32, - ), - 6 => array( - 'var' => 'srcFilePath', - 'type' => TType::STRING, - ), - 7 => array( - 'var' => 'srcHostCredToken', - 'type' => TType::STRING, - ), - 8 => array( - 'var' => 'destHostname', - 'type' => TType::STRING, - ), - 9 => array( - 'var' => 'destLoginName', - 'type' => TType::STRING, - ), - 10 => array( - 'var' => 'destPort', - 'type' => TType::I64, - ), - 11 => array( - 'var' => 'destProtocol', - 'type' => TType::I32, - ), - 12 => array( - 'var' => 'destFilePath', - 'type' => TType::STRING, - ), - 13 => array( - 'var' => 'destHostCredToken', - 'type' => TType::STRING, - ), - 14 => array( - 'var' => 'fileTransferMode', - 'type' => TType::I32, - ), - 15 => array( - 'var' => 'transferStatus', - 'type' => TType::I32, - ), - 16 => array( - 'var' => 'fileSize', - 'type' => TType::I64, - ), - 17 => array( - 'var' => 'transferTime', - 'type' => TType::I64, - ), - 18 => array( - 'var' => 'createdTime', - 'type' => TType::I64, - ), - 19 => array( - 'var' => 'lastModifiedType', - 'type' => TType::I64, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['transferId'])) { - $this->transferId = $vals['transferId']; - } - if (isset($vals['srcHostname'])) { - $this->srcHostname = $vals['srcHostname']; - } - if (isset($vals['srcLoginName'])) { - $this->srcLoginName = $vals['srcLoginName']; - } - if (isset($vals['srcPort'])) { - $this->srcPort = $vals['srcPort']; - } - if (isset($vals['srcProtocol'])) { - $this->srcProtocol = $vals['srcProtocol']; - } - if (isset($vals['srcFilePath'])) { - $this->srcFilePath = $vals['srcFilePath']; - } - if (isset($vals['srcHostCredToken'])) { - $this->srcHostCredToken = $vals['srcHostCredToken']; - } - if (isset($vals['destHostname'])) { - $this->destHostname = $vals['destHostname']; - } - if (isset($vals['destLoginName'])) { - $this->destLoginName = $vals['destLoginName']; - } - if (isset($vals['destPort'])) { - $this->destPort = $vals['destPort']; - } - if (isset($vals['destProtocol'])) { - $this->destProtocol = $vals['destProtocol']; - } - if (isset($vals['destFilePath'])) { - $this->destFilePath = $vals['destFilePath']; - } - if (isset($vals['destHostCredToken'])) { - $this->destHostCredToken = $vals['destHostCredToken']; - } - if (isset($vals['fileTransferMode'])) { - $this->fileTransferMode = $vals['fileTransferMode']; - } - if (isset($vals['transferStatus'])) { - $this->transferStatus = $vals['transferStatus']; - } - if (isset($vals['fileSize'])) { - $this->fileSize = $vals['fileSize']; - } - if (isset($vals['transferTime'])) { - $this->transferTime = $vals['transferTime']; - } - if (isset($vals['createdTime'])) { - $this->createdTime = $vals['createdTime']; - } - if (isset($vals['lastModifiedType'])) { - $this->lastModifiedType = $vals['lastModifiedType']; - } - } - } - - public function getName() { - return 'FileTransferRequest'; - } - - 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->transferId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->srcHostname); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->srcLoginName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->srcPort); - } else { - $xfer += $input->skip($ftype); - } - break; - case 5: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->srcProtocol); - } else { - $xfer += $input->skip($ftype); - } - break; - case 6: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->srcFilePath); - } else { - $xfer += $input->skip($ftype); - } - break; - case 7: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->srcHostCredToken); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->destHostname); - } else { - $xfer += $input->skip($ftype); - } - break; - case 9: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->destLoginName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 10: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->destPort); - } else { - $xfer += $input->skip($ftype); - } - break; - case 11: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->destProtocol); - } else { - $xfer += $input->skip($ftype); - } - break; - case 12: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->destFilePath); - } else { - $xfer += $input->skip($ftype); - } - break; - case 13: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->destHostCredToken); - } else { - $xfer += $input->skip($ftype); - } - break; - case 14: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->fileTransferMode); - } else { - $xfer += $input->skip($ftype); - } - break; - case 15: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->transferStatus); - } else { - $xfer += $input->skip($ftype); - } - break; - case 16: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->fileSize); - } else { - $xfer += $input->skip($ftype); - } - break; - case 17: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->transferTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 18: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->createdTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 19: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->lastModifiedType); - } 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('FileTransferRequest'); - if ($this->transferId !== null) { - $xfer += $output->writeFieldBegin('transferId', TType::STRING, 1); - $xfer += $output->writeString($this->transferId); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcHostname !== null) { - $xfer += $output->writeFieldBegin('srcHostname', TType::STRING, 2); - $xfer += $output->writeString($this->srcHostname); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcLoginName !== null) { - $xfer += $output->writeFieldBegin('srcLoginName', TType::STRING, 3); - $xfer += $output->writeString($this->srcLoginName); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcPort !== null) { - $xfer += $output->writeFieldBegin('srcPort', TType::I64, 4); - $xfer += $output->writeI64($this->srcPort); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcProtocol !== null) { - $xfer += $output->writeFieldBegin('srcProtocol', TType::I32, 5); - $xfer += $output->writeI32($this->srcProtocol); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcFilePath !== null) { - $xfer += $output->writeFieldBegin('srcFilePath', TType::STRING, 6); - $xfer += $output->writeString($this->srcFilePath); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcHostCredToken !== null) { - $xfer += $output->writeFieldBegin('srcHostCredToken', TType::STRING, 7); - $xfer += $output->writeString($this->srcHostCredToken); - $xfer += $output->writeFieldEnd(); - } - if ($this->destHostname !== null) { - $xfer += $output->writeFieldBegin('destHostname', TType::STRING, 8); - $xfer += $output->writeString($this->destHostname); - $xfer += $output->writeFieldEnd(); - } - if ($this->destLoginName !== null) { - $xfer += $output->writeFieldBegin('destLoginName', TType::STRING, 9); - $xfer += $output->writeString($this->destLoginName); - $xfer += $output->writeFieldEnd(); - } - if ($this->destPort !== null) { - $xfer += $output->writeFieldBegin('destPort', TType::I64, 10); - $xfer += $output->writeI64($this->destPort); - $xfer += $output->writeFieldEnd(); - } - if ($this->destProtocol !== null) { - $xfer += $output->writeFieldBegin('destProtocol', TType::I32, 11); - $xfer += $output->writeI32($this->destProtocol); - $xfer += $output->writeFieldEnd(); - } - if ($this->destFilePath !== null) { - $xfer += $output->writeFieldBegin('destFilePath', TType::STRING, 12); - $xfer += $output->writeString($this->destFilePath); - $xfer += $output->writeFieldEnd(); - } - if ($this->destHostCredToken !== null) { - $xfer += $output->writeFieldBegin('destHostCredToken', TType::STRING, 13); - $xfer += $output->writeString($this->destHostCredToken); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileTransferMode !== null) { - $xfer += $output->writeFieldBegin('fileTransferMode', TType::I32, 14); - $xfer += $output->writeI32($this->fileTransferMode); - $xfer += $output->writeFieldEnd(); - } - if ($this->transferStatus !== null) { - $xfer += $output->writeFieldBegin('transferStatus', TType::I32, 15); - $xfer += $output->writeI32($this->transferStatus); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileSize !== null) { - $xfer += $output->writeFieldBegin('fileSize', TType::I64, 16); - $xfer += $output->writeI64($this->fileSize); - $xfer += $output->writeFieldEnd(); - } - if ($this->transferTime !== null) { - $xfer += $output->writeFieldBegin('transferTime', TType::I64, 17); - $xfer += $output->writeI64($this->transferTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->createdTime !== null) { - $xfer += $output->writeFieldBegin('createdTime', TType::I64, 18); - $xfer += $output->writeI64($this->createdTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->lastModifiedType !== null) { - $xfer += $output->writeFieldBegin('lastModifiedType', TType::I64, 19); - $xfer += $output->writeI64($this->lastModifiedType); - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - -class FileNode { - static $_TSPEC; - - /** - * @var int - */ - public $type = null; - /** - * @var int - */ - public $size = null; - /** - * @var string - */ - public $nativeType = null; - /** - * @var string - */ - public $name = null; - /** - * @var string - */ - public $path = null; - /** - * @var string - */ - public $storageHostName = null; - /** - * @var int - */ - public $lastModifiedType = null; - /** - * @var int - */ - public $createdTime = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'type', - 'type' => TType::I32, - ), - 2 => array( - 'var' => 'size', - 'type' => TType::I64, - ), - 3 => array( - 'var' => 'nativeType', - 'type' => TType::STRING, - ), - 4 => array( - 'var' => 'name', - 'type' => TType::STRING, - ), - 5 => array( - 'var' => 'path', - 'type' => TType::STRING, - ), - 6 => array( - 'var' => 'storageHostName', - 'type' => TType::STRING, - ), - 7 => array( - 'var' => 'lastModifiedType', - 'type' => TType::I64, - ), - 8 => array( - 'var' => 'createdTime', - 'type' => TType::I64, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['type'])) { - $this->type = $vals['type']; - } - if (isset($vals['size'])) { - $this->size = $vals['size']; - } - if (isset($vals['nativeType'])) { - $this->nativeType = $vals['nativeType']; - } - if (isset($vals['name'])) { - $this->name = $vals['name']; - } - if (isset($vals['path'])) { - $this->path = $vals['path']; - } - if (isset($vals['storageHostName'])) { - $this->storageHostName = $vals['storageHostName']; - } - if (isset($vals['lastModifiedType'])) { - $this->lastModifiedType = $vals['lastModifiedType']; - } - if (isset($vals['createdTime'])) { - $this->createdTime = $vals['createdTime']; - } - } - } - - public function getName() { - return 'FileNode'; - } - - 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->type); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->size); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->nativeType); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->name); - } else { - $xfer += $input->skip($ftype); - } - break; - case 5: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->path); - } else { - $xfer += $input->skip($ftype); - } - break; - case 6: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->storageHostName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 7: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->lastModifiedType); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->createdTime); - } 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('FileNode'); - if ($this->type !== null) { - $xfer += $output->writeFieldBegin('type', TType::I32, 1); - $xfer += $output->writeI32($this->type); - $xfer += $output->writeFieldEnd(); - } - if ($this->size !== null) { - $xfer += $output->writeFieldBegin('size', TType::I64, 2); - $xfer += $output->writeI64($this->size); - $xfer += $output->writeFieldEnd(); - } - if ($this->nativeType !== null) { - $xfer += $output->writeFieldBegin('nativeType', TType::STRING, 3); - $xfer += $output->writeString($this->nativeType); - $xfer += $output->writeFieldEnd(); - } - if ($this->name !== null) { - $xfer += $output->writeFieldBegin('name', TType::STRING, 4); - $xfer += $output->writeString($this->name); - $xfer += $output->writeFieldEnd(); - } - if ($this->path !== null) { - $xfer += $output->writeFieldBegin('path', TType::STRING, 5); - $xfer += $output->writeString($this->path); - $xfer += $output->writeFieldEnd(); - } - if ($this->storageHostName !== null) { - $xfer += $output->writeFieldBegin('storageHostName', TType::STRING, 6); - $xfer += $output->writeString($this->storageHostName); - $xfer += $output->writeFieldEnd(); - } - if ($this->lastModifiedType !== null) { - $xfer += $output->writeFieldBegin('lastModifiedType', TType::I64, 7); - $xfer += $output->writeI64($this->lastModifiedType); - $xfer += $output->writeFieldEnd(); - } - if ($this->createdTime !== null) { - $xfer += $output->writeFieldBegin('createdTime', TType::I64, 8); - $xfer += $output->writeI64($this->createdTime); - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - - http://git-wip-us.apache.org/repos/asf/airavata/blob/b61cfcd3/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/metadata/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/metadata/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/metadata/Types.php new file mode 100644 index 0000000..aa25b92 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/metadata/Types.php @@ -0,0 +1,371 @@ + 'FILE', + 1 => 'COLLECTION', + ); +} + +class MetadataModel { + static $_TSPEC; + + /** + * @var string + */ + public $metadataId = null; + /** + * @var string + */ + public $gatewayId = null; + /** + * @var string + */ + public $username = null; + /** + * @var string[] + */ + public $sharedUsers = null; + /** + * @var bool + */ + public $sharedPublic = null; + /** + * @var string + */ + public $userFriendlyName = null; + /** + * @var string + */ + public $userFriendlyDescription = null; + /** + * @var int + */ + public $metadataType = null; + /** + * @var string + */ + public $associatedEntityId = null; + /** + * @var array + */ + public $customInformation = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'metadataId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'gatewayId', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'username', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'sharedUsers', + 'type' => TType::LST, + 'etype' => TType::STRING, + 'elem' => array( + 'type' => TType::STRING, + ), + ), + 5 => array( + 'var' => 'sharedPublic', + 'type' => TType::BOOL, + ), + 6 => array( + 'var' => 'userFriendlyName', + 'type' => TType::STRING, + ), + 7 => array( + 'var' => 'userFriendlyDescription', + 'type' => TType::STRING, + ), + 8 => array( + 'var' => 'metadataType', + 'type' => TType::I32, + ), + 9 => array( + 'var' => 'associatedEntityId', + 'type' => TType::STRING, + ), + 10 => array( + 'var' => 'customInformation', + '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['metadataId'])) { + $this->metadataId = $vals['metadataId']; + } + if (isset($vals['gatewayId'])) { + $this->gatewayId = $vals['gatewayId']; + } + if (isset($vals['username'])) { + $this->username = $vals['username']; + } + if (isset($vals['sharedUsers'])) { + $this->sharedUsers = $vals['sharedUsers']; + } + if (isset($vals['sharedPublic'])) { + $this->sharedPublic = $vals['sharedPublic']; + } + if (isset($vals['userFriendlyName'])) { + $this->userFriendlyName = $vals['userFriendlyName']; + } + if (isset($vals['userFriendlyDescription'])) { + $this->userFriendlyDescription = $vals['userFriendlyDescription']; + } + if (isset($vals['metadataType'])) { + $this->metadataType = $vals['metadataType']; + } + if (isset($vals['associatedEntityId'])) { + $this->associatedEntityId = $vals['associatedEntityId']; + } + if (isset($vals['customInformation'])) { + $this->customInformation = $vals['customInformation']; + } + } + } + + public function getName() { + return 'MetadataModel'; + } + + 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->metadataId); + } 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->username); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::LST) { + $this->sharedUsers = array(); + $_size0 = 0; + $_etype3 = 0; + $xfer += $input->readListBegin($_etype3, $_size0); + for ($_i4 = 0; $_i4 < $_size0; ++$_i4) + { + $elem5 = null; + $xfer += $input->readString($elem5); + $this->sharedUsers []= $elem5; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->sharedPublic); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->userFriendlyName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->userFriendlyDescription); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->metadataType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->associatedEntityId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::MAP) { + $this->customInformation = array(); + $_size6 = 0; + $_ktype7 = 0; + $_vtype8 = 0; + $xfer += $input->readMapBegin($_ktype7, $_vtype8, $_size6); + for ($_i10 = 0; $_i10 < $_size6; ++$_i10) + { + $key11 = ''; + $val12 = ''; + $xfer += $input->readString($key11); + $xfer += $input->readString($val12); + $this->customInformation[$key11] = $val12; + } + $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('MetadataModel'); + if ($this->metadataId !== null) { + $xfer += $output->writeFieldBegin('metadataId', TType::STRING, 1); + $xfer += $output->writeString($this->metadataId); + $xfer += $output->writeFieldEnd(); + } + if ($this->gatewayId !== null) { + $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 2); + $xfer += $output->writeString($this->gatewayId); + $xfer += $output->writeFieldEnd(); + } + if ($this->username !== null) { + $xfer += $output->writeFieldBegin('username', TType::STRING, 3); + $xfer += $output->writeString($this->username); + $xfer += $output->writeFieldEnd(); + } + if ($this->sharedUsers !== null) { + if (!is_array($this->sharedUsers)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('sharedUsers', TType::LST, 4); + { + $output->writeListBegin(TType::STRING, count($this->sharedUsers)); + { + foreach ($this->sharedUsers as $iter13) + { + $xfer += $output->writeString($iter13); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->sharedPublic !== null) { + $xfer += $output->writeFieldBegin('sharedPublic', TType::BOOL, 5); + $xfer += $output->writeBool($this->sharedPublic); + $xfer += $output->writeFieldEnd(); + } + if ($this->userFriendlyName !== null) { + $xfer += $output->writeFieldBegin('userFriendlyName', TType::STRING, 6); + $xfer += $output->writeString($this->userFriendlyName); + $xfer += $output->writeFieldEnd(); + } + if ($this->userFriendlyDescription !== null) { + $xfer += $output->writeFieldBegin('userFriendlyDescription', TType::STRING, 7); + $xfer += $output->writeString($this->userFriendlyDescription); + $xfer += $output->writeFieldEnd(); + } + if ($this->metadataType !== null) { + $xfer += $output->writeFieldBegin('metadataType', TType::I32, 8); + $xfer += $output->writeI32($this->metadataType); + $xfer += $output->writeFieldEnd(); + } + if ($this->associatedEntityId !== null) { + $xfer += $output->writeFieldBegin('associatedEntityId', TType::STRING, 9); + $xfer += $output->writeString($this->associatedEntityId); + $xfer += $output->writeFieldEnd(); + } + if ($this->customInformation !== null) { + if (!is_array($this->customInformation)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('customInformation', TType::MAP, 10); + { + $output->writeMapBegin(TType::STRING, TType::STRING, count($this->customInformation)); + { + foreach ($this->customInformation as $kiter14 => $viter15) + { + $xfer += $output->writeString($kiter14); + $xfer += $output->writeString($viter15); + } + } + $output->writeMapEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + + http://git-wip-us.apache.org/repos/asf/airavata/blob/b61cfcd3/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Replica/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Replica/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Replica/Types.php deleted file mode 100644 index d846e18..0000000 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Replica/Types.php +++ /dev/null @@ -1,923 +0,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 string - */ - public $sha256Checksum = null; - /** - * @var int - */ - public $dataResourceType = null; - /** - * @var int - */ - public $resourceSize = null; - /** - * @var string - */ - public $nativeFormat = null; - /** - * @var int - */ - public $creationTime = null; - /** - * @var int - */ - public $lastModifiedTime = null; - /** - * @var array - */ - public $resourceMetadata = null; - /** - * @var \Airavata\Model\Replica\DataReplicaLocationModel[] - */ - public $replicaLocations = null; - /** - * @var \Airavata\Model\Replica\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' => 'sha256Checksum', - 'type' => TType::STRING, - ), - 8 => array( - 'var' => 'dataResourceType', - 'type' => TType::I32, - ), - 9 => array( - 'var' => 'resourceSize', - 'type' => TType::I32, - ), - 10 => array( - 'var' => 'nativeFormat', - 'type' => TType::STRING, - ), - 11 => array( - 'var' => 'creationTime', - 'type' => TType::I64, - ), - 12 => array( - 'var' => 'lastModifiedTime', - 'type' => TType::I64, - ), - 13 => array( - 'var' => 'resourceMetadata', - 'type' => TType::MAP, - 'ktype' => TType::STRING, - 'vtype' => TType::STRING, - 'key' => array( - 'type' => TType::STRING, - ), - 'val' => array( - 'type' => TType::STRING, - ), - ), - 14 => array( - 'var' => 'replicaLocations', - 'type' => TType::LST, - 'etype' => TType::STRUCT, - 'elem' => array( - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Replica\DataReplicaLocationModel', - ), - ), - 15 => array( - 'var' => 'childResources', - 'type' => TType::LST, - 'etype' => TType::STRUCT, - 'elem' => array( - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Replica\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['sha256Checksum'])) { - $this->sha256Checksum = $vals['sha256Checksum']; - } - if (isset($vals['dataResourceType'])) { - $this->dataResourceType = $vals['dataResourceType']; - } - if (isset($vals['resourceSize'])) { - $this->resourceSize = $vals['resourceSize']; - } - if (isset($vals['nativeFormat'])) { - $this->nativeFormat = $vals['nativeFormat']; - } - 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::STRING) { - $xfer += $input->readString($this->sha256Checksum); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->dataResourceType); - } else { - $xfer += $input->skip($ftype); - } - break; - case 9: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->resourceSize); - } else { - $xfer += $input->skip($ftype); - } - break; - case 10: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->nativeFormat); - } else { - $xfer += $input->skip($ftype); - } - break; - case 11: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->creationTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 12: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->lastModifiedTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 13: - 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 14: - 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\Replica\DataReplicaLocationModel(); - $xfer += $elem12->read($input); - $this->replicaLocations []= $elem12; - } - $xfer += $input->readListEnd(); - } else { - $xfer += $input->skip($ftype); - } - break; - case 15: - 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\Replica\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->sha256Checksum !== null) { - $xfer += $output->writeFieldBegin('sha256Checksum', TType::STRING, 7); - $xfer += $output->writeString($this->sha256Checksum); - $xfer += $output->writeFieldEnd(); - } - if ($this->dataResourceType !== null) { - $xfer += $output->writeFieldBegin('dataResourceType', TType::I32, 8); - $xfer += $output->writeI32($this->dataResourceType); - $xfer += $output->writeFieldEnd(); - } - if ($this->resourceSize !== null) { - $xfer += $output->writeFieldBegin('resourceSize', TType::I32, 9); - $xfer += $output->writeI32($this->resourceSize); - $xfer += $output->writeFieldEnd(); - } - if ($this->nativeFormat !== null) { - $xfer += $output->writeFieldBegin('nativeFormat', TType::STRING, 10); - $xfer += $output->writeString($this->nativeFormat); - $xfer += $output->writeFieldEnd(); - } - if ($this->creationTime !== null) { - $xfer += $output->writeFieldBegin('creationTime', TType::I64, 11); - $xfer += $output->writeI64($this->creationTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->lastModifiedTime !== null) { - $xfer += $output->writeFieldBegin('lastModifiedTime', TType::I64, 12); - $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, 13); - { - $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, 14); - { - $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, 15); - { - $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 string - */ - public $sourceReplicaId = 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' => 'sourceReplicaId', - 'type' => TType::STRING, - ), - 6 => array( - 'var' => 'creationTime', - 'type' => TType::I64, - ), - 7 => array( - 'var' => 'lastModifiedTime', - 'type' => TType::I64, - ), - 8 => array( - 'var' => 'validUntilTime', - 'type' => TType::I64, - ), - 9 => array( - 'var' => 'replicaLocationCategory', - 'type' => TType::I32, - ), - 10 => array( - 'var' => 'replicaPersistentType', - 'type' => TType::I32, - ), - 11 => array( - 'var' => 'storageResourceId', - 'type' => TType::STRING, - ), - 12 => array( - 'var' => 'fileAbsolutePath', - 'type' => TType::STRING, - ), - 13 => 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['sourceReplicaId'])) { - $this->sourceReplicaId = $vals['sourceReplicaId']; - } - 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::STRING) { - $xfer += $input->readString($this->sourceReplicaId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 6: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->creationTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 7: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->lastModifiedTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->validUntilTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 9: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->replicaLocationCategory); - } else { - $xfer += $input->skip($ftype); - } - break; - case 10: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->replicaPersistentType); - } else { - $xfer += $input->skip($ftype); - } - break; - case 11: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->storageResourceId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 12: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->fileAbsolutePath); - } else { - $xfer += $input->skip($ftype); - } - break; - case 13: - 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->sourceReplicaId !== null) { - $xfer += $output->writeFieldBegin('sourceReplicaId', TType::STRING, 5); - $xfer += $output->writeString($this->sourceReplicaId); - $xfer += $output->writeFieldEnd(); - } - if ($this->creationTime !== null) { - $xfer += $output->writeFieldBegin('creationTime', TType::I64, 6); - $xfer += $output->writeI64($this->creationTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->lastModifiedTime !== null) { - $xfer += $output->writeFieldBegin('lastModifiedTime', TType::I64, 7); - $xfer += $output->writeI64($this->lastModifiedTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->validUntilTime !== null) { - $xfer += $output->writeFieldBegin('validUntilTime', TType::I64, 8); - $xfer += $output->writeI64($this->validUntilTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->replicaLocationCategory !== null) { - $xfer += $output->writeFieldBegin('replicaLocationCategory', TType::I32, 9); - $xfer += $output->writeI32($this->replicaLocationCategory); - $xfer += $output->writeFieldEnd(); - } - if ($this->replicaPersistentType !== null) { - $xfer += $output->writeFieldBegin('replicaPersistentType', TType::I32, 10); - $xfer += $output->writeI32($this->replicaPersistentType); - $xfer += $output->writeFieldEnd(); - } - if ($this->storageResourceId !== null) { - $xfer += $output->writeFieldBegin('storageResourceId', TType::STRING, 11); - $xfer += $output->writeString($this->storageResourceId); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileAbsolutePath !== null) { - $xfer += $output->writeFieldBegin('fileAbsolutePath', TType::STRING, 12); - $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, 13); - { - $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/blob/b61cfcd3/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/AiravataClientFactory.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/AiravataClientFactory.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/AiravataClientFactory.php deleted file mode 100644 index 95882b5..0000000 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/AiravataClientFactory.php +++ /dev/null @@ -1,77 +0,0 @@ - - - - - - - - - - - - - - - - - -airavataServerHost = isset($options['airavataServerHost']) ? $options['airavataServerHost'] : null; - $this->airavataServerPort = isset($options['airavataServerPort']) ? $options['airavataServerPort'] : null; - - $this->appCatalogServerHost = isset($options['appCatalogServerHost']) ? $options['appCatalogServerHost'] : null; - $this->appCatalogServerPort = isset($options['appCatalogServerPort']) ? $options['appCatalogServerPort'] : null; - } - - public function getAiravataClient() - { - $transport = new TSocket($this->airavataServerHost, $this->airavataServerPort); - $protocol = new TBinaryProtocol($transport); - $transport->open(); - return new AiravataClient($protocol); - } - - public function getApplicationCatalogClient() - { - $transport = new TSocket($this->appCatalogServerHost, $this->appCatalogServerPort); - $protocol = new TBinaryProtocol($transport); - $transport->open(); - return new AiravataClient($protocol); - } -} - http://git-wip-us.apache.org/repos/asf/airavata/blob/b61cfcd3/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/Base/TBase.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/Base/TBase.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/Base/TBase.php deleted file mode 100644 index 3d5b526..0000000 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/Base/TBase.php +++ /dev/null @@ -1,367 +0,0 @@ - 'Bool', - TType::BYTE => 'Byte', - TType::I16 => 'I16', - TType::I32 => 'I32', - TType::I64 => 'I64', - TType::DOUBLE => 'Double', - TType::STRING => 'String'); - - abstract function read($input); - - abstract function write($output); - - public function __construct($spec=null, $vals=null) { - if (is_array($spec) && is_array($vals)) { - foreach ($spec as $fid => $fspec) { - $var = $fspec['var']; - if (isset($vals[$var])) { - $this->$var = $vals[$var]; - } - } - } - } - - public function __wakeup() - { - $this->__construct(get_object_vars($this)); - } - - private function _readMap(&$var, $spec, $input) { - $xfer = 0; - $ktype = $spec['ktype']; - $vtype = $spec['vtype']; - $kread = $vread = null; - if (isset(TBase::$tmethod[$ktype])) { - $kread = 'read'.TBase::$tmethod[$ktype]; - } else { - $kspec = $spec['key']; - } - if (isset(TBase::$tmethod[$vtype])) { - $vread = 'read'.TBase::$tmethod[$vtype]; - } else { - $vspec = $spec['val']; - } - $var = array(); - $_ktype = $_vtype = $size = 0; - $xfer += $input->readMapBegin($_ktype, $_vtype, $size); - for ($i = 0; $i < $size; ++$i) { - $key = $val = null; - if ($kread !== null) { - $xfer += $input->$kread($key); - } else { - switch ($ktype) { - case TType::STRUCT: - $class = $kspec['class']; - $key = new $class(); - $xfer += $key->read($input); - break; - case TType::MAP: - $xfer += $this->_readMap($key, $kspec, $input); - break; - case TType::LST: - $xfer += $this->_readList($key, $kspec, $input, false); - break; - case TType::SET: - $xfer += $this->_readList($key, $kspec, $input, true); - break; - } - } - if ($vread !== null) { - $xfer += $input->$vread($val); - } else { - switch ($vtype) { - case TType::STRUCT: - $class = $vspec['class']; - $val = new $class(); - $xfer += $val->read($input); - break; - case TType::MAP: - $xfer += $this->_readMap($val, $vspec, $input); - break; - case TType::LST: - $xfer += $this->_readList($val, $vspec, $input, false); - break; - case TType::SET: - $xfer += $this->_readList($val, $vspec, $input, true); - break; - } - } - $var[$key] = $val; - } - $xfer += $input->readMapEnd(); - return $xfer; - } - - private function _readList(&$var, $spec, $input, $set=false) { - $xfer = 0; - $etype = $spec['etype']; - $eread = $vread = null; - if (isset(TBase::$tmethod[$etype])) { - $eread = 'read'.TBase::$tmethod[$etype]; - } else { - $espec = $spec['elem']; - } - $var = array(); - $_etype = $size = 0; - if ($set) { - $xfer += $input->readSetBegin($_etype, $size); - } else { - $xfer += $input->readListBegin($_etype, $size); - } - for ($i = 0; $i < $size; ++$i) { - $elem = null; - if ($eread !== null) { - $xfer += $input->$eread($elem); - } else { - $espec = $spec['elem']; - switch ($etype) { - case TType::STRUCT: - $class = $espec['class']; - $elem = new $class(); - $xfer += $elem->read($input); - break; - case TType::MAP: - $xfer += $this->_readMap($elem, $espec, $input); - break; - case TType::LST: - $xfer += $this->_readList($elem, $espec, $input, false); - break; - case TType::SET: - $xfer += $this->_readList($elem, $espec, $input, true); - break; - } - } - if ($set) { - $var[$elem] = true; - } else { - $var []= $elem; - } - } - if ($set) { - $xfer += $input->readSetEnd(); - } else { - $xfer += $input->readListEnd(); - } - return $xfer; - } - - protected function _read($class, $spec, $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; - } - if (isset($spec[$fid])) { - $fspec = $spec[$fid]; - $var = $fspec['var']; - if ($ftype == $fspec['type']) { - $xfer = 0; - if (isset(TBase::$tmethod[$ftype])) { - $func = 'read'.TBase::$tmethod[$ftype]; - $xfer += $input->$func($this->$var); - } else { - switch ($ftype) { - case TType::STRUCT: - $class = $fspec['class']; - $this->$var = new $class(); - $xfer += $this->$var->read($input); - break; - case TType::MAP: - $xfer += $this->_readMap($this->$var, $fspec, $input); - break; - case TType::LST: - $xfer += $this->_readList($this->$var, $fspec, $input, false); - break; - case TType::SET: - $xfer += $this->_readList($this->$var, $fspec, $input, true); - break; - } - } - } else { - $xfer += $input->skip($ftype); - } - } else { - $xfer += $input->skip($ftype); - } - $xfer += $input->readFieldEnd(); - } - $xfer += $input->readStructEnd(); - return $xfer; - } - - private function _writeMap($var, $spec, $output) { - $xfer = 0; - $ktype = $spec['ktype']; - $vtype = $spec['vtype']; - $kwrite = $vwrite = null; - if (isset(TBase::$tmethod[$ktype])) { - $kwrite = 'write'.TBase::$tmethod[$ktype]; - } else { - $kspec = $spec['key']; - } - if (isset(TBase::$tmethod[$vtype])) { - $vwrite = 'write'.TBase::$tmethod[$vtype]; - } else { - $vspec = $spec['val']; - } - $xfer += $output->writeMapBegin($ktype, $vtype, count($var)); - foreach ($var as $key => $val) { - if (isset($kwrite)) { - $xfer += $output->$kwrite($key); - } else { - switch ($ktype) { - case TType::STRUCT: - $xfer += $key->write($output); - break; - case TType::MAP: - $xfer += $this->_writeMap($key, $kspec, $output); - break; - case TType::LST: - $xfer += $this->_writeList($key, $kspec, $output, false); - break; - case TType::SET: - $xfer += $this->_writeList($key, $kspec, $output, true); - break; - } - } - if (isset($vwrite)) { - $xfer += $output->$vwrite($val); - } else { - switch ($vtype) { - case TType::STRUCT: - $xfer += $val->write($output); - break; - case TType::MAP: - $xfer += $this->_writeMap($val, $vspec, $output); - break; - case TType::LST: - $xfer += $this->_writeList($val, $vspec, $output, false); - break; - case TType::SET: - $xfer += $this->_writeList($val, $vspec, $output, true); - break; - } - } - } - $xfer += $output->writeMapEnd(); - return $xfer; - } - - private function _writeList($var, $spec, $output, $set=false) { - $xfer = 0; - $etype = $spec['etype']; - $ewrite = null; - if (isset(TBase::$tmethod[$etype])) { - $ewrite = 'write'.TBase::$tmethod[$etype]; - } else { - $espec = $spec['elem']; - } - if ($set) { - $xfer += $output->writeSetBegin($etype, count($var)); - } else { - $xfer += $output->writeListBegin($etype, count($var)); - } - foreach ($var as $key => $val) { - $elem = $set ? $key : $val; - if (isset($ewrite)) { - $xfer += $output->$ewrite($elem); - } else { - switch ($etype) { - case TType::STRUCT: - $xfer += $elem->write($output); - break; - case TType::MAP: - $xfer += $this->_writeMap($elem, $espec, $output); - break; - case TType::LST: - $xfer += $this->_writeList($elem, $espec, $output, false); - break; - case TType::SET: - $xfer += $this->_writeList($elem, $espec, $output, true); - break; - } - } - } - if ($set) { - $xfer += $output->writeSetEnd(); - } else { - $xfer += $output->writeListEnd(); - } - return $xfer; - } - - protected function _write($class, $spec, $output) { - $xfer = 0; - $xfer += $output->writeStructBegin($class); - foreach ($spec as $fid => $fspec) { - $var = $fspec['var']; - if ($this->$var !== null) { - $ftype = $fspec['type']; - $xfer += $output->writeFieldBegin($var, $ftype, $fid); - if (isset(TBase::$tmethod[$ftype])) { - $func = 'write'.TBase::$tmethod[$ftype]; - $xfer += $output->$func($this->$var); - } else { - switch ($ftype) { - case TType::STRUCT: - $xfer += $this->$var->write($output); - break; - case TType::MAP: - $xfer += $this->_writeMap($this->$var, $fspec, $output); - break; - case TType::LST: - $xfer += $this->_writeList($this->$var, $fspec, $output, false); - break; - case TType::SET: - $xfer += $this->_writeList($this->$var, $fspec, $output, true); - break; - } - } - $xfer += $output->writeFieldEnd(); - } - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } -} http://git-wip-us.apache.org/repos/asf/airavata/blob/b61cfcd3/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/ClassLoader/ThriftClassLoader.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/ClassLoader/ThriftClassLoader.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/ClassLoader/ThriftClassLoader.php deleted file mode 100644 index bce93f5..0000000 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/ClassLoader/ThriftClassLoader.php +++ /dev/null @@ -1,223 +0,0 @@ -apc = $apc; - $this->apc_prefix = $apc_prefix; - } - - /** - * Registers a namespace. - * - * @param string $namespace The namespace - * @param array|string $paths The location(s) of the namespace - */ - public function registerNamespace($namespace, $paths) - { - $this->namespaces[$namespace] = (array) $paths; - } - - /** - * Registers a Thrift definition namespace. - * - * @param string $namespace The definition namespace - * @param array|string $paths The location(s) of the definition namespace - */ - public function registerDefinition($namespace, $paths) - { - $this->definitions[$namespace] = (array) $paths; - } - - /** - * Registers this instance as an autoloader. - * - * @param Boolean $prepend Whether to prepend the autoloader or not - */ - public function register($prepend = false) - { - spl_autoload_register(array($this, 'loadClass'), true, $prepend); - } - - /** - * Loads the given class, definition or interface. - * - * @param string $class The name of the class - */ - public function loadClass($class) - { - if ( - (true === $this->apc && ($file = $this->findFileInApc($class))) or - ($file = $this->findFile($class)) - ) - { - require_once $file; - } - } - - /** - * Loads the given class or interface in APC. - * @param string $class The name of the class - * @return string - */ - protected function findFileInApc($class) - { - if (false === $file = apc_fetch($this->apc_prefix.$class)) { - apc_store($this->apc_prefix.$class, $file = $this->findFile($class)); - } - - return $file; - } - - /** - * Find class in namespaces or definitions directories - * @param string $class - * @return string - */ - public function findFile($class) - { - // Remove first backslash - if ('\\' == $class[0]) - { - $class = substr($class, 1); - } - - if (false !== $pos = strrpos($class, '\\')) - { - // Namespaced class name - $namespace = substr($class, 0, $pos); - - // Iterate in normal namespaces - foreach ($this->namespaces as $ns => $dirs) - { - //Don't interfere with other autoloaders - if (0 !== strpos($namespace, $ns)) - { - continue; - } - - foreach ($dirs as $dir) - { - $className = substr($class, $pos + 1); - - $file = $dir.DIRECTORY_SEPARATOR. - str_replace('\\', DIRECTORY_SEPARATOR, $namespace). - DIRECTORY_SEPARATOR. - $className.'.php'; - - if (file_exists($file)) - { - return $file; - } - } - } - - // Iterate in Thrift namespaces - - // Remove first part of namespace - $m = explode('\\', $class); - - // Ignore wrong call - if(count($m) <= 1) - { - return; - } - - $class = array_pop($m); - $namespace = implode('\\', $m); - - foreach ($this->definitions as $ns => $dirs) - { - //Don't interfere with other autoloaders - if (0 !== strpos($namespace, $ns)) - { - continue; - } - - foreach ($dirs as $dir) - { - /** - * Available in service: Interface, Client, Processor, Rest - * And every service methods (_.+) - */ - if( - 0 === preg_match('#(.+)(if|client|processor|rest)$#i', $class, $n) and - 0 === preg_match('#(.+)_[a-z0-9]+_(args|result)$#i', $class, $n) - ) - { - $className = 'Types'; - } - else - { - $className = $n[1]; - } - - $file = $dir.DIRECTORY_SEPARATOR . - str_replace('\\', DIRECTORY_SEPARATOR, $namespace) . - DIRECTORY_SEPARATOR . - $className . '.php'; - - if (file_exists($file)) - { - return $file; - } - } - } - } - } -} http://git-wip-us.apache.org/repos/asf/airavata/blob/b61cfcd3/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/Exception/TApplicationException.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/Exception/TApplicationException.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/Exception/TApplicationException.php deleted file mode 100644 index 9081973..0000000 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Thrift/Exception/TApplicationException.php +++ /dev/null @@ -1,72 +0,0 @@ - array('var' => 'message', - 'type' => TType::STRING), - 2 => array('var' => 'code', - 'type' => TType::I32)); - - const UNKNOWN = 0; - const UNKNOWN_METHOD = 1; - const INVALID_MESSAGE_TYPE = 2; - const WRONG_METHOD_NAME = 3; - const BAD_SEQUENCE_ID = 4; - const MISSING_RESULT = 5; - const INTERNAL_ERROR = 6; - const PROTOCOL_ERROR = 7; - const INVALID_TRANSFORM = 8; - const INVALID_PROTOCOL = 9; - const UNSUPPORTED_CLIENT_TYPE = 10; - - function __construct($message=null, $code=0) { - parent::__construct($message, $code); - } - - public function read($output) { - return $this->_read('TApplicationException', self::$_TSPEC, $output); - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('TApplicationException'); - if ($message = $this->getMessage()) { - $xfer += $output->writeFieldBegin('message', TType::STRING, 1); - $xfer += $output->writeString($message); - $xfer += $output->writeFieldEnd(); - } - if ($code = $this->getCode()) { - $xfer += $output->writeFieldBegin('type', TType::I32, 2); - $xfer += $output->writeI32($code); - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } -}