You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2014/07/03 16:15:09 UTC
[1/3] Updating ComputeResource Namespace to align with application
descrrptions - AIRAVATA-1203
Repository: airavata
Updated Branches:
refs/heads/master 169e6f9d1 -> 0a002531b
http://git-wip-us.apache.org/repos/asf/airavata/blob/0a002531/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/ComputeHost/Types.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/ComputeHost/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/ComputeHost/Types.php
deleted file mode 100644
index 8f347f2..0000000
--- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/ComputeHost/Types.php
+++ /dev/null
@@ -1,1262 +0,0 @@
-<?php
-namespace Airavata\Model\ComputeHost;
-
-/**
- * Autogenerated by Thrift Compiler (0.9.1)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-use Thrift\Base\TBase;
-use Thrift\Type\TType;
-use Thrift\Type\TMessageType;
-use Thrift\Exception\TException;
-use Thrift\Exception\TProtocolException;
-use Thrift\Protocol\TProtocol;
-use Thrift\Protocol\TBinaryProtocolAccelerated;
-use Thrift\Exception\TApplicationException;
-
-
-final class ResourceJobManager {
- const FORK = 0;
- const PBS = 1;
- const UGE = 2;
- const SLURM = 3;
- static public $__names = array(
- 0 => 'FORK',
- 1 => 'PBS',
- 2 => 'UGE',
- 3 => 'SLURM',
- );
-}
-
-final class JobSubmissionProtocol {
- const SSH = 0;
- const GSISSH = 1;
- const GRAM = 2;
- const UNICORE = 3;
- static public $__names = array(
- 0 => 'SSH',
- 1 => 'GSISSH',
- 2 => 'GRAM',
- 3 => 'UNICORE',
- );
-}
-
-final class DataMovementProtocol {
- const SCP = 0;
- const SFTP = 1;
- const GridFTP = 2;
- const UNICORE_STORAGE_SERVICE = 3;
- static public $__names = array(
- 0 => 'SCP',
- 1 => 'SFTP',
- 2 => 'GridFTP',
- 3 => 'UNICORE_STORAGE_SERVICE',
- );
-}
-
-final class SecurityProtocol {
- const USERNAME_PASSWORD = 0;
- const SSH_KEYS = 1;
- const GSI = 2;
- const KERBEROS = 3;
- const OAUTH = 4;
- static public $__names = array(
- 0 => 'USERNAME_PASSWORD',
- 1 => 'SSH_KEYS',
- 2 => 'GSI',
- 3 => 'KERBEROS',
- 4 => 'OAUTH',
- );
-}
-
-class SCPDataMovement {
- static $_TSPEC;
-
- public $dataMovementDataID = "DO_NOT_SET_AT_CLIENTS";
- public $securityProtocol = null;
- public $sshPort = 22;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'dataMovementDataID',
- 'type' => TType::STRING,
- ),
- 2 => array(
- 'var' => 'securityProtocol',
- 'type' => TType::I32,
- ),
- 3 => array(
- 'var' => 'sshPort',
- 'type' => TType::I32,
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['dataMovementDataID'])) {
- $this->dataMovementDataID = $vals['dataMovementDataID'];
- }
- if (isset($vals['securityProtocol'])) {
- $this->securityProtocol = $vals['securityProtocol'];
- }
- if (isset($vals['sshPort'])) {
- $this->sshPort = $vals['sshPort'];
- }
- }
- }
-
- public function getName() {
- return 'SCPDataMovement';
- }
-
- public function read($input)
- {
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
- {
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 1:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->dataMovementDataID);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 2:
- if ($ftype == TType::I32) {
- $xfer += $input->readI32($this->securityProtocol);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 3:
- if ($ftype == TType::I32) {
- $xfer += $input->readI32($this->sshPort);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
- }
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('SCPDataMovement');
- if ($this->dataMovementDataID !== null) {
- $xfer += $output->writeFieldBegin('dataMovementDataID', TType::STRING, 1);
- $xfer += $output->writeString($this->dataMovementDataID);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->securityProtocol !== null) {
- $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
- $xfer += $output->writeI32($this->securityProtocol);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->sshPort !== null) {
- $xfer += $output->writeFieldBegin('sshPort', TType::I32, 3);
- $xfer += $output->writeI32($this->sshPort);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class GridFTPDataMovement {
- static $_TSPEC;
-
- public $dataMovementDataID = "DO_NOT_SET_AT_CLIENTS";
- public $securityProtocol = null;
- public $gridFTPEndPoint = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'dataMovementDataID',
- 'type' => TType::STRING,
- ),
- 2 => array(
- 'var' => 'securityProtocol',
- 'type' => TType::I32,
- ),
- 3 => array(
- 'var' => 'gridFTPEndPoint',
- 'type' => TType::LST,
- 'etype' => TType::STRING,
- 'elem' => array(
- 'type' => TType::STRING,
- ),
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['dataMovementDataID'])) {
- $this->dataMovementDataID = $vals['dataMovementDataID'];
- }
- if (isset($vals['securityProtocol'])) {
- $this->securityProtocol = $vals['securityProtocol'];
- }
- if (isset($vals['gridFTPEndPoint'])) {
- $this->gridFTPEndPoint = $vals['gridFTPEndPoint'];
- }
- }
- }
-
- public function getName() {
- return 'GridFTPDataMovement';
- }
-
- public function read($input)
- {
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
- {
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 1:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->dataMovementDataID);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 2:
- if ($ftype == TType::I32) {
- $xfer += $input->readI32($this->securityProtocol);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 3:
- if ($ftype == TType::LST) {
- $this->gridFTPEndPoint = array();
- $_size0 = 0;
- $_etype3 = 0;
- $xfer += $input->readListBegin($_etype3, $_size0);
- for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
- {
- $elem5 = null;
- $xfer += $input->readString($elem5);
- $this->gridFTPEndPoint []= $elem5;
- }
- $xfer += $input->readListEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
- }
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('GridFTPDataMovement');
- if ($this->dataMovementDataID !== null) {
- $xfer += $output->writeFieldBegin('dataMovementDataID', TType::STRING, 1);
- $xfer += $output->writeString($this->dataMovementDataID);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->securityProtocol !== null) {
- $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
- $xfer += $output->writeI32($this->securityProtocol);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->gridFTPEndPoint !== null) {
- if (!is_array($this->gridFTPEndPoint)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('gridFTPEndPoint', TType::LST, 3);
- {
- $output->writeListBegin(TType::STRING, count($this->gridFTPEndPoint));
- {
- foreach ($this->gridFTPEndPoint as $iter6)
- {
- $xfer += $output->writeString($iter6);
- }
- }
- $output->writeListEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class SSHJobSubmission {
- static $_TSPEC;
-
- public $jobSubmissionDataID = "DO_NOT_SET_AT_CLIENTS";
- public $resourceJobManager = null;
- public $sshPort = 22;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'jobSubmissionDataID',
- 'type' => TType::STRING,
- ),
- 2 => array(
- 'var' => 'resourceJobManager',
- 'type' => TType::I32,
- ),
- 3 => array(
- 'var' => 'sshPort',
- 'type' => TType::I32,
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['jobSubmissionDataID'])) {
- $this->jobSubmissionDataID = $vals['jobSubmissionDataID'];
- }
- if (isset($vals['resourceJobManager'])) {
- $this->resourceJobManager = $vals['resourceJobManager'];
- }
- if (isset($vals['sshPort'])) {
- $this->sshPort = $vals['sshPort'];
- }
- }
- }
-
- public function getName() {
- return 'SSHJobSubmission';
- }
-
- public function read($input)
- {
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
- {
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 1:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->jobSubmissionDataID);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 2:
- if ($ftype == TType::I32) {
- $xfer += $input->readI32($this->resourceJobManager);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 3:
- if ($ftype == TType::I32) {
- $xfer += $input->readI32($this->sshPort);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
- }
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('SSHJobSubmission');
- if ($this->jobSubmissionDataID !== null) {
- $xfer += $output->writeFieldBegin('jobSubmissionDataID', TType::STRING, 1);
- $xfer += $output->writeString($this->jobSubmissionDataID);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->resourceJobManager !== null) {
- $xfer += $output->writeFieldBegin('resourceJobManager', TType::I32, 2);
- $xfer += $output->writeI32($this->resourceJobManager);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->sshPort !== null) {
- $xfer += $output->writeFieldBegin('sshPort', TType::I32, 3);
- $xfer += $output->writeI32($this->sshPort);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class GlobusJobSubmission {
- static $_TSPEC;
-
- public $jobSubmissionDataID = "DO_NOT_SET_AT_CLIENTS";
- public $securityProtocol = null;
- public $resourceJobManager = null;
- public $globusGateKeeperEndPoint = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'jobSubmissionDataID',
- 'type' => TType::STRING,
- ),
- 2 => array(
- 'var' => 'securityProtocol',
- 'type' => TType::I32,
- ),
- 3 => array(
- 'var' => 'resourceJobManager',
- 'type' => TType::I32,
- ),
- 4 => array(
- 'var' => 'globusGateKeeperEndPoint',
- 'type' => TType::LST,
- 'etype' => TType::STRING,
- 'elem' => array(
- 'type' => TType::STRING,
- ),
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['jobSubmissionDataID'])) {
- $this->jobSubmissionDataID = $vals['jobSubmissionDataID'];
- }
- if (isset($vals['securityProtocol'])) {
- $this->securityProtocol = $vals['securityProtocol'];
- }
- if (isset($vals['resourceJobManager'])) {
- $this->resourceJobManager = $vals['resourceJobManager'];
- }
- if (isset($vals['globusGateKeeperEndPoint'])) {
- $this->globusGateKeeperEndPoint = $vals['globusGateKeeperEndPoint'];
- }
- }
- }
-
- public function getName() {
- return 'GlobusJobSubmission';
- }
-
- public function read($input)
- {
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
- {
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 1:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->jobSubmissionDataID);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 2:
- if ($ftype == TType::I32) {
- $xfer += $input->readI32($this->securityProtocol);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 3:
- if ($ftype == TType::I32) {
- $xfer += $input->readI32($this->resourceJobManager);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 4:
- if ($ftype == TType::LST) {
- $this->globusGateKeeperEndPoint = array();
- $_size7 = 0;
- $_etype10 = 0;
- $xfer += $input->readListBegin($_etype10, $_size7);
- for ($_i11 = 0; $_i11 < $_size7; ++$_i11)
- {
- $elem12 = null;
- $xfer += $input->readString($elem12);
- $this->globusGateKeeperEndPoint []= $elem12;
- }
- $xfer += $input->readListEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
- }
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('GlobusJobSubmission');
- if ($this->jobSubmissionDataID !== null) {
- $xfer += $output->writeFieldBegin('jobSubmissionDataID', TType::STRING, 1);
- $xfer += $output->writeString($this->jobSubmissionDataID);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->securityProtocol !== null) {
- $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
- $xfer += $output->writeI32($this->securityProtocol);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->resourceJobManager !== null) {
- $xfer += $output->writeFieldBegin('resourceJobManager', TType::I32, 3);
- $xfer += $output->writeI32($this->resourceJobManager);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->globusGateKeeperEndPoint !== null) {
- if (!is_array($this->globusGateKeeperEndPoint)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('globusGateKeeperEndPoint', TType::LST, 4);
- {
- $output->writeListBegin(TType::STRING, count($this->globusGateKeeperEndPoint));
- {
- foreach ($this->globusGateKeeperEndPoint as $iter13)
- {
- $xfer += $output->writeString($iter13);
- }
- }
- $output->writeListEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class GSISSHJobSubmission {
- static $_TSPEC;
-
- public $jobSubmissionDataID = "DO_NOT_SET_AT_CLIENTS";
- public $resourceJobManager = null;
- public $sshPort = 22;
- public $exports = null;
- public $preJobCommands = null;
- public $postJobCommands = null;
- public $installedPath = null;
- public $monitorMode = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'jobSubmissionDataID',
- 'type' => TType::STRING,
- ),
- 2 => array(
- 'var' => 'resourceJobManager',
- 'type' => TType::I32,
- ),
- 3 => array(
- 'var' => 'sshPort',
- 'type' => TType::I32,
- ),
- 4 => array(
- 'var' => 'exports',
- 'type' => TType::SET,
- 'etype' => TType::STRING,
- 'elem' => array(
- 'type' => TType::STRING,
- ),
- ),
- 5 => array(
- 'var' => 'preJobCommands',
- 'type' => TType::LST,
- 'etype' => TType::STRING,
- 'elem' => array(
- 'type' => TType::STRING,
- ),
- ),
- 6 => array(
- 'var' => 'postJobCommands',
- 'type' => TType::LST,
- 'etype' => TType::STRING,
- 'elem' => array(
- 'type' => TType::STRING,
- ),
- ),
- 7 => array(
- 'var' => 'installedPath',
- 'type' => TType::STRING,
- ),
- 8 => array(
- 'var' => 'monitorMode',
- 'type' => TType::STRING,
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['jobSubmissionDataID'])) {
- $this->jobSubmissionDataID = $vals['jobSubmissionDataID'];
- }
- if (isset($vals['resourceJobManager'])) {
- $this->resourceJobManager = $vals['resourceJobManager'];
- }
- if (isset($vals['sshPort'])) {
- $this->sshPort = $vals['sshPort'];
- }
- if (isset($vals['exports'])) {
- $this->exports = $vals['exports'];
- }
- if (isset($vals['preJobCommands'])) {
- $this->preJobCommands = $vals['preJobCommands'];
- }
- if (isset($vals['postJobCommands'])) {
- $this->postJobCommands = $vals['postJobCommands'];
- }
- if (isset($vals['installedPath'])) {
- $this->installedPath = $vals['installedPath'];
- }
- if (isset($vals['monitorMode'])) {
- $this->monitorMode = $vals['monitorMode'];
- }
- }
- }
-
- public function getName() {
- return 'GSISSHJobSubmission';
- }
-
- 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->jobSubmissionDataID);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 2:
- if ($ftype == TType::I32) {
- $xfer += $input->readI32($this->resourceJobManager);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 3:
- if ($ftype == TType::I32) {
- $xfer += $input->readI32($this->sshPort);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 4:
- if ($ftype == TType::SET) {
- $this->exports = array();
- $_size14 = 0;
- $_etype17 = 0;
- $xfer += $input->readSetBegin($_etype17, $_size14);
- for ($_i18 = 0; $_i18 < $_size14; ++$_i18)
- {
- $elem19 = null;
- $xfer += $input->readString($elem19);
- if (is_scalar($elem19)) {
- $this->exports[$elem19] = true;
- } else {
- $this->exports []= $elem19;
- }
- }
- $xfer += $input->readSetEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 5:
- if ($ftype == TType::LST) {
- $this->preJobCommands = array();
- $_size20 = 0;
- $_etype23 = 0;
- $xfer += $input->readListBegin($_etype23, $_size20);
- for ($_i24 = 0; $_i24 < $_size20; ++$_i24)
- {
- $elem25 = null;
- $xfer += $input->readString($elem25);
- $this->preJobCommands []= $elem25;
- }
- $xfer += $input->readListEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 6:
- if ($ftype == TType::LST) {
- $this->postJobCommands = array();
- $_size26 = 0;
- $_etype29 = 0;
- $xfer += $input->readListBegin($_etype29, $_size26);
- for ($_i30 = 0; $_i30 < $_size26; ++$_i30)
- {
- $elem31 = null;
- $xfer += $input->readString($elem31);
- $this->postJobCommands []= $elem31;
- }
- $xfer += $input->readListEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 7:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->installedPath);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 8:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->monitorMode);
- } 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('GSISSHJobSubmission');
- if ($this->jobSubmissionDataID !== null) {
- $xfer += $output->writeFieldBegin('jobSubmissionDataID', TType::STRING, 1);
- $xfer += $output->writeString($this->jobSubmissionDataID);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->resourceJobManager !== null) {
- $xfer += $output->writeFieldBegin('resourceJobManager', TType::I32, 2);
- $xfer += $output->writeI32($this->resourceJobManager);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->sshPort !== null) {
- $xfer += $output->writeFieldBegin('sshPort', TType::I32, 3);
- $xfer += $output->writeI32($this->sshPort);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->exports !== null) {
- if (!is_array($this->exports)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('exports', TType::SET, 4);
- {
- $output->writeSetBegin(TType::STRING, count($this->exports));
- {
- foreach ($this->exports as $iter32 => $iter33)
- {
- if (is_scalar($iter33)) {
- $xfer += $output->writeString($iter32);
- } else {
- $xfer += $output->writeString($iter33);
- }
- }
- }
- $output->writeSetEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- if ($this->preJobCommands !== null) {
- if (!is_array($this->preJobCommands)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('preJobCommands', TType::LST, 5);
- {
- $output->writeListBegin(TType::STRING, count($this->preJobCommands));
- {
- foreach ($this->preJobCommands as $iter34)
- {
- $xfer += $output->writeString($iter34);
- }
- }
- $output->writeListEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- if ($this->postJobCommands !== null) {
- if (!is_array($this->postJobCommands)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('postJobCommands', TType::LST, 6);
- {
- $output->writeListBegin(TType::STRING, count($this->postJobCommands));
- {
- foreach ($this->postJobCommands as $iter35)
- {
- $xfer += $output->writeString($iter35);
- }
- }
- $output->writeListEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- if ($this->installedPath !== null) {
- $xfer += $output->writeFieldBegin('installedPath', TType::STRING, 7);
- $xfer += $output->writeString($this->installedPath);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->monitorMode !== null) {
- $xfer += $output->writeFieldBegin('monitorMode', TType::STRING, 8);
- $xfer += $output->writeString($this->monitorMode);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class ComputeResourceDescription {
- static $_TSPEC;
-
- public $isEmpty = false;
- public $resourceId = "DO_NOT_SET_AT_CLIENTS";
- public $hostName = null;
- public $hostAliases = null;
- public $ipAddresses = null;
- public $resourceDescription = null;
- public $preferredJobSubmissionProtocol = null;
- public $jobSubmissionProtocols = null;
- public $dataMovementProtocols = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'isEmpty',
- 'type' => TType::BOOL,
- ),
- 2 => array(
- 'var' => 'resourceId',
- 'type' => TType::STRING,
- ),
- 3 => array(
- 'var' => 'hostName',
- 'type' => TType::STRING,
- ),
- 4 => array(
- 'var' => 'hostAliases',
- 'type' => TType::SET,
- 'etype' => TType::STRING,
- 'elem' => array(
- 'type' => TType::STRING,
- ),
- ),
- 5 => array(
- 'var' => 'ipAddresses',
- 'type' => TType::SET,
- 'etype' => TType::STRING,
- 'elem' => array(
- 'type' => TType::STRING,
- ),
- ),
- 6 => array(
- 'var' => 'resourceDescription',
- 'type' => TType::STRING,
- ),
- 8 => array(
- 'var' => 'preferredJobSubmissionProtocol',
- 'type' => TType::STRING,
- ),
- 9 => array(
- 'var' => 'jobSubmissionProtocols',
- 'type' => TType::MAP,
- 'ktype' => TType::STRING,
- 'vtype' => TType::I32,
- 'key' => array(
- 'type' => TType::STRING,
- ),
- 'val' => array(
- 'type' => TType::I32,
- ),
- ),
- 10 => array(
- 'var' => 'dataMovementProtocols',
- 'type' => TType::MAP,
- 'ktype' => TType::STRING,
- 'vtype' => TType::I32,
- 'key' => array(
- 'type' => TType::STRING,
- ),
- 'val' => array(
- 'type' => TType::I32,
- ),
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['isEmpty'])) {
- $this->isEmpty = $vals['isEmpty'];
- }
- if (isset($vals['resourceId'])) {
- $this->resourceId = $vals['resourceId'];
- }
- if (isset($vals['hostName'])) {
- $this->hostName = $vals['hostName'];
- }
- if (isset($vals['hostAliases'])) {
- $this->hostAliases = $vals['hostAliases'];
- }
- if (isset($vals['ipAddresses'])) {
- $this->ipAddresses = $vals['ipAddresses'];
- }
- if (isset($vals['resourceDescription'])) {
- $this->resourceDescription = $vals['resourceDescription'];
- }
- if (isset($vals['preferredJobSubmissionProtocol'])) {
- $this->preferredJobSubmissionProtocol = $vals['preferredJobSubmissionProtocol'];
- }
- if (isset($vals['jobSubmissionProtocols'])) {
- $this->jobSubmissionProtocols = $vals['jobSubmissionProtocols'];
- }
- if (isset($vals['dataMovementProtocols'])) {
- $this->dataMovementProtocols = $vals['dataMovementProtocols'];
- }
- }
- }
-
- public function getName() {
- return 'ComputeResourceDescription';
- }
-
- public function read($input)
- {
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
- {
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 1:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->isEmpty);
- } 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->hostName);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 4:
- if ($ftype == TType::SET) {
- $this->hostAliases = array();
- $_size36 = 0;
- $_etype39 = 0;
- $xfer += $input->readSetBegin($_etype39, $_size36);
- for ($_i40 = 0; $_i40 < $_size36; ++$_i40)
- {
- $elem41 = null;
- $xfer += $input->readString($elem41);
- if (is_scalar($elem41)) {
- $this->hostAliases[$elem41] = true;
- } else {
- $this->hostAliases []= $elem41;
- }
- }
- $xfer += $input->readSetEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 5:
- if ($ftype == TType::SET) {
- $this->ipAddresses = array();
- $_size42 = 0;
- $_etype45 = 0;
- $xfer += $input->readSetBegin($_etype45, $_size42);
- for ($_i46 = 0; $_i46 < $_size42; ++$_i46)
- {
- $elem47 = null;
- $xfer += $input->readString($elem47);
- if (is_scalar($elem47)) {
- $this->ipAddresses[$elem47] = true;
- } else {
- $this->ipAddresses []= $elem47;
- }
- }
- $xfer += $input->readSetEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 6:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->resourceDescription);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 8:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->preferredJobSubmissionProtocol);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 9:
- if ($ftype == TType::MAP) {
- $this->jobSubmissionProtocols = array();
- $_size48 = 0;
- $_ktype49 = 0;
- $_vtype50 = 0;
- $xfer += $input->readMapBegin($_ktype49, $_vtype50, $_size48);
- for ($_i52 = 0; $_i52 < $_size48; ++$_i52)
- {
- $key53 = '';
- $val54 = 0;
- $xfer += $input->readString($key53);
- $xfer += $input->readI32($val54);
- $this->jobSubmissionProtocols[$key53] = $val54;
- }
- $xfer += $input->readMapEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 10:
- if ($ftype == TType::MAP) {
- $this->dataMovementProtocols = array();
- $_size55 = 0;
- $_ktype56 = 0;
- $_vtype57 = 0;
- $xfer += $input->readMapBegin($_ktype56, $_vtype57, $_size55);
- for ($_i59 = 0; $_i59 < $_size55; ++$_i59)
- {
- $key60 = '';
- $val61 = 0;
- $xfer += $input->readString($key60);
- $xfer += $input->readI32($val61);
- $this->dataMovementProtocols[$key60] = $val61;
- }
- $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('ComputeResourceDescription');
- if ($this->isEmpty !== null) {
- $xfer += $output->writeFieldBegin('isEmpty', TType::BOOL, 1);
- $xfer += $output->writeBool($this->isEmpty);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->resourceId !== null) {
- $xfer += $output->writeFieldBegin('resourceId', TType::STRING, 2);
- $xfer += $output->writeString($this->resourceId);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->hostName !== null) {
- $xfer += $output->writeFieldBegin('hostName', TType::STRING, 3);
- $xfer += $output->writeString($this->hostName);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->hostAliases !== null) {
- if (!is_array($this->hostAliases)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('hostAliases', TType::SET, 4);
- {
- $output->writeSetBegin(TType::STRING, count($this->hostAliases));
- {
- foreach ($this->hostAliases as $iter62 => $iter63)
- {
- if (is_scalar($iter63)) {
- $xfer += $output->writeString($iter62);
- } else {
- $xfer += $output->writeString($iter63);
- }
- }
- }
- $output->writeSetEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- if ($this->ipAddresses !== null) {
- if (!is_array($this->ipAddresses)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('ipAddresses', TType::SET, 5);
- {
- $output->writeSetBegin(TType::STRING, count($this->ipAddresses));
- {
- foreach ($this->ipAddresses as $iter64 => $iter65)
- {
- if (is_scalar($iter65)) {
- $xfer += $output->writeString($iter64);
- } else {
- $xfer += $output->writeString($iter65);
- }
- }
- }
- $output->writeSetEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- if ($this->resourceDescription !== null) {
- $xfer += $output->writeFieldBegin('resourceDescription', TType::STRING, 6);
- $xfer += $output->writeString($this->resourceDescription);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->preferredJobSubmissionProtocol !== null) {
- $xfer += $output->writeFieldBegin('preferredJobSubmissionProtocol', TType::STRING, 8);
- $xfer += $output->writeString($this->preferredJobSubmissionProtocol);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->jobSubmissionProtocols !== null) {
- if (!is_array($this->jobSubmissionProtocols)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('jobSubmissionProtocols', TType::MAP, 9);
- {
- $output->writeMapBegin(TType::STRING, TType::I32, count($this->jobSubmissionProtocols));
- {
- foreach ($this->jobSubmissionProtocols as $kiter66 => $viter67)
- {
- $xfer += $output->writeString($kiter66);
- $xfer += $output->writeI32($viter67);
- }
- }
- $output->writeMapEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- if ($this->dataMovementProtocols !== null) {
- if (!is_array($this->dataMovementProtocols)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('dataMovementProtocols', TType::MAP, 10);
- {
- $output->writeMapBegin(TType::STRING, TType::I32, count($this->dataMovementProtocols));
- {
- foreach ($this->dataMovementProtocols as $kiter68 => $viter69)
- {
- $xfer += $output->writeString($kiter68);
- $xfer += $output->writeI32($viter69);
- }
- }
- $output->writeMapEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-$GLOBALS['computeResourceModel_CONSTANTS']['DEFAULT_ID'] = "DO_NOT_SET_AT_CLIENTS";
-
-
[2/3] Updating ComputeResource Namespace to align with application
descrrptions - AIRAVATA-1203
Posted by sm...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/0a002531/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_types.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_types.cpp
new file mode 100644
index 0000000..2ee33d4
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_types.cpp
@@ -0,0 +1,1025 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.1)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#include "computeResourceModel_types.h"
+
+#include <algorithm>
+
+
+
+int _kResourceJobManagerValues[] = {
+ ResourceJobManager::FORK,
+ ResourceJobManager::PBS,
+ ResourceJobManager::UGE,
+ ResourceJobManager::SLURM
+};
+const char* _kResourceJobManagerNames[] = {
+ "FORK",
+ "PBS",
+ "UGE",
+ "SLURM"
+};
+const std::map<int, const char*> _ResourceJobManager_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4, _kResourceJobManagerValues, _kResourceJobManagerNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
+
+int _kJobSubmissionProtocolValues[] = {
+ JobSubmissionProtocol::SSH,
+ JobSubmissionProtocol::GSISSH,
+ JobSubmissionProtocol::GRAM,
+ JobSubmissionProtocol::UNICORE
+};
+const char* _kJobSubmissionProtocolNames[] = {
+ "SSH",
+ "GSISSH",
+ "GRAM",
+ "UNICORE"
+};
+const std::map<int, const char*> _JobSubmissionProtocol_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4, _kJobSubmissionProtocolValues, _kJobSubmissionProtocolNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
+
+int _kDataMovementProtocolValues[] = {
+ DataMovementProtocol::SCP,
+ DataMovementProtocol::SFTP,
+ DataMovementProtocol::GridFTP,
+ DataMovementProtocol::UNICORE_STORAGE_SERVICE
+};
+const char* _kDataMovementProtocolNames[] = {
+ "SCP",
+ "SFTP",
+ "GridFTP",
+ "UNICORE_STORAGE_SERVICE"
+};
+const std::map<int, const char*> _DataMovementProtocol_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4, _kDataMovementProtocolValues, _kDataMovementProtocolNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
+
+int _kSecurityProtocolValues[] = {
+ SecurityProtocol::USERNAME_PASSWORD,
+ SecurityProtocol::SSH_KEYS,
+ SecurityProtocol::GSI,
+ SecurityProtocol::KERBEROS,
+ SecurityProtocol::OAUTH
+};
+const char* _kSecurityProtocolNames[] = {
+ "USERNAME_PASSWORD",
+ "SSH_KEYS",
+ "GSI",
+ "KERBEROS",
+ "OAUTH"
+};
+const std::map<int, const char*> _SecurityProtocol_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(5, _kSecurityProtocolValues, _kSecurityProtocolNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
+
+const char* SCPDataMovement::ascii_fingerprint = "FEB6B2CD28861B4EED855CACA1FEF2CB";
+const uint8_t SCPDataMovement::binary_fingerprint[16] = {0xFE,0xB6,0xB2,0xCD,0x28,0x86,0x1B,0x4E,0xED,0x85,0x5C,0xAC,0xA1,0xFE,0xF2,0xCB};
+
+uint32_t SCPDataMovement::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_dataMovementDataID = false;
+ bool isset_securityProtocol = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->dataMovementDataID);
+ isset_dataMovementDataID = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ int32_t ecast0;
+ xfer += iprot->readI32(ecast0);
+ this->securityProtocol = (SecurityProtocol::type)ecast0;
+ isset_securityProtocol = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->sshPort);
+ this->__isset.sshPort = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_dataMovementDataID)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_securityProtocol)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t SCPDataMovement::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("SCPDataMovement");
+
+ xfer += oprot->writeFieldBegin("dataMovementDataID", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->dataMovementDataID);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("securityProtocol", ::apache::thrift::protocol::T_I32, 2);
+ xfer += oprot->writeI32((int32_t)this->securityProtocol);
+ xfer += oprot->writeFieldEnd();
+
+ if (this->__isset.sshPort) {
+ xfer += oprot->writeFieldBegin("sshPort", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeI32(this->sshPort);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(SCPDataMovement &a, SCPDataMovement &b) {
+ using ::std::swap;
+ swap(a.dataMovementDataID, b.dataMovementDataID);
+ swap(a.securityProtocol, b.securityProtocol);
+ swap(a.sshPort, b.sshPort);
+ swap(a.__isset, b.__isset);
+}
+
+const char* GridFTPDataMovement::ascii_fingerprint = "790EE8B1D56A3B9B76C41DD063726E75";
+const uint8_t GridFTPDataMovement::binary_fingerprint[16] = {0x79,0x0E,0xE8,0xB1,0xD5,0x6A,0x3B,0x9B,0x76,0xC4,0x1D,0xD0,0x63,0x72,0x6E,0x75};
+
+uint32_t GridFTPDataMovement::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_dataMovementDataID = false;
+ bool isset_securityProtocol = false;
+ bool isset_gridFTPEndPoint = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->dataMovementDataID);
+ isset_dataMovementDataID = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ int32_t ecast1;
+ xfer += iprot->readI32(ecast1);
+ this->securityProtocol = (SecurityProtocol::type)ecast1;
+ isset_securityProtocol = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->gridFTPEndPoint.clear();
+ uint32_t _size2;
+ ::apache::thrift::protocol::TType _etype5;
+ xfer += iprot->readListBegin(_etype5, _size2);
+ this->gridFTPEndPoint.resize(_size2);
+ uint32_t _i6;
+ for (_i6 = 0; _i6 < _size2; ++_i6)
+ {
+ xfer += iprot->readString(this->gridFTPEndPoint[_i6]);
+ }
+ xfer += iprot->readListEnd();
+ }
+ isset_gridFTPEndPoint = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_dataMovementDataID)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_securityProtocol)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_gridFTPEndPoint)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t GridFTPDataMovement::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("GridFTPDataMovement");
+
+ xfer += oprot->writeFieldBegin("dataMovementDataID", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->dataMovementDataID);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("securityProtocol", ::apache::thrift::protocol::T_I32, 2);
+ xfer += oprot->writeI32((int32_t)this->securityProtocol);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("gridFTPEndPoint", ::apache::thrift::protocol::T_LIST, 3);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->gridFTPEndPoint.size()));
+ std::vector<std::string> ::const_iterator _iter7;
+ for (_iter7 = this->gridFTPEndPoint.begin(); _iter7 != this->gridFTPEndPoint.end(); ++_iter7)
+ {
+ xfer += oprot->writeString((*_iter7));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(GridFTPDataMovement &a, GridFTPDataMovement &b) {
+ using ::std::swap;
+ swap(a.dataMovementDataID, b.dataMovementDataID);
+ swap(a.securityProtocol, b.securityProtocol);
+ swap(a.gridFTPEndPoint, b.gridFTPEndPoint);
+}
+
+const char* SSHJobSubmission::ascii_fingerprint = "FEB6B2CD28861B4EED855CACA1FEF2CB";
+const uint8_t SSHJobSubmission::binary_fingerprint[16] = {0xFE,0xB6,0xB2,0xCD,0x28,0x86,0x1B,0x4E,0xED,0x85,0x5C,0xAC,0xA1,0xFE,0xF2,0xCB};
+
+uint32_t SSHJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_jobSubmissionDataID = false;
+ bool isset_resourceJobManager = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->jobSubmissionDataID);
+ isset_jobSubmissionDataID = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ int32_t ecast8;
+ xfer += iprot->readI32(ecast8);
+ this->resourceJobManager = (ResourceJobManager::type)ecast8;
+ isset_resourceJobManager = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->sshPort);
+ this->__isset.sshPort = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_jobSubmissionDataID)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_resourceJobManager)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t SSHJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("SSHJobSubmission");
+
+ xfer += oprot->writeFieldBegin("jobSubmissionDataID", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->jobSubmissionDataID);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("resourceJobManager", ::apache::thrift::protocol::T_I32, 2);
+ xfer += oprot->writeI32((int32_t)this->resourceJobManager);
+ xfer += oprot->writeFieldEnd();
+
+ if (this->__isset.sshPort) {
+ xfer += oprot->writeFieldBegin("sshPort", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeI32(this->sshPort);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(SSHJobSubmission &a, SSHJobSubmission &b) {
+ using ::std::swap;
+ swap(a.jobSubmissionDataID, b.jobSubmissionDataID);
+ swap(a.resourceJobManager, b.resourceJobManager);
+ swap(a.sshPort, b.sshPort);
+ swap(a.__isset, b.__isset);
+}
+
+const char* GlobusJobSubmission::ascii_fingerprint = "DF4253F78D7B543C16FA461660D38A03";
+const uint8_t GlobusJobSubmission::binary_fingerprint[16] = {0xDF,0x42,0x53,0xF7,0x8D,0x7B,0x54,0x3C,0x16,0xFA,0x46,0x16,0x60,0xD3,0x8A,0x03};
+
+uint32_t GlobusJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_jobSubmissionDataID = false;
+ bool isset_securityProtocol = false;
+ bool isset_resourceJobManager = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->jobSubmissionDataID);
+ isset_jobSubmissionDataID = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ int32_t ecast9;
+ xfer += iprot->readI32(ecast9);
+ this->securityProtocol = (SecurityProtocol::type)ecast9;
+ isset_securityProtocol = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ int32_t ecast10;
+ xfer += iprot->readI32(ecast10);
+ this->resourceJobManager = (ResourceJobManager::type)ecast10;
+ isset_resourceJobManager = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->globusGateKeeperEndPoint.clear();
+ uint32_t _size11;
+ ::apache::thrift::protocol::TType _etype14;
+ xfer += iprot->readListBegin(_etype14, _size11);
+ this->globusGateKeeperEndPoint.resize(_size11);
+ uint32_t _i15;
+ for (_i15 = 0; _i15 < _size11; ++_i15)
+ {
+ xfer += iprot->readString(this->globusGateKeeperEndPoint[_i15]);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.globusGateKeeperEndPoint = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_jobSubmissionDataID)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_securityProtocol)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_resourceJobManager)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t GlobusJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("GlobusJobSubmission");
+
+ xfer += oprot->writeFieldBegin("jobSubmissionDataID", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->jobSubmissionDataID);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("securityProtocol", ::apache::thrift::protocol::T_I32, 2);
+ xfer += oprot->writeI32((int32_t)this->securityProtocol);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("resourceJobManager", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeI32((int32_t)this->resourceJobManager);
+ xfer += oprot->writeFieldEnd();
+
+ if (this->__isset.globusGateKeeperEndPoint) {
+ xfer += oprot->writeFieldBegin("globusGateKeeperEndPoint", ::apache::thrift::protocol::T_LIST, 4);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->globusGateKeeperEndPoint.size()));
+ std::vector<std::string> ::const_iterator _iter16;
+ for (_iter16 = this->globusGateKeeperEndPoint.begin(); _iter16 != this->globusGateKeeperEndPoint.end(); ++_iter16)
+ {
+ xfer += oprot->writeString((*_iter16));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(GlobusJobSubmission &a, GlobusJobSubmission &b) {
+ using ::std::swap;
+ swap(a.jobSubmissionDataID, b.jobSubmissionDataID);
+ swap(a.securityProtocol, b.securityProtocol);
+ swap(a.resourceJobManager, b.resourceJobManager);
+ swap(a.globusGateKeeperEndPoint, b.globusGateKeeperEndPoint);
+ swap(a.__isset, b.__isset);
+}
+
+const char* GSISSHJobSubmission::ascii_fingerprint = "6969A7F145C4403B2F9081A498E933FD";
+const uint8_t GSISSHJobSubmission::binary_fingerprint[16] = {0x69,0x69,0xA7,0xF1,0x45,0xC4,0x40,0x3B,0x2F,0x90,0x81,0xA4,0x98,0xE9,0x33,0xFD};
+
+uint32_t GSISSHJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_jobSubmissionDataID = false;
+ bool isset_resourceJobManager = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->jobSubmissionDataID);
+ isset_jobSubmissionDataID = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ int32_t ecast17;
+ xfer += iprot->readI32(ecast17);
+ this->resourceJobManager = (ResourceJobManager::type)ecast17;
+ isset_resourceJobManager = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->sshPort);
+ this->__isset.sshPort = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_SET) {
+ {
+ this->exports.clear();
+ uint32_t _size18;
+ ::apache::thrift::protocol::TType _etype21;
+ xfer += iprot->readSetBegin(_etype21, _size18);
+ uint32_t _i22;
+ for (_i22 = 0; _i22 < _size18; ++_i22)
+ {
+ std::string _elem23;
+ xfer += iprot->readString(_elem23);
+ this->exports.insert(_elem23);
+ }
+ xfer += iprot->readSetEnd();
+ }
+ this->__isset.exports = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 5:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->preJobCommands.clear();
+ uint32_t _size24;
+ ::apache::thrift::protocol::TType _etype27;
+ xfer += iprot->readListBegin(_etype27, _size24);
+ this->preJobCommands.resize(_size24);
+ uint32_t _i28;
+ for (_i28 = 0; _i28 < _size24; ++_i28)
+ {
+ xfer += iprot->readString(this->preJobCommands[_i28]);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.preJobCommands = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 6:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->postJobCommands.clear();
+ uint32_t _size29;
+ ::apache::thrift::protocol::TType _etype32;
+ xfer += iprot->readListBegin(_etype32, _size29);
+ this->postJobCommands.resize(_size29);
+ uint32_t _i33;
+ for (_i33 = 0; _i33 < _size29; ++_i33)
+ {
+ xfer += iprot->readString(this->postJobCommands[_i33]);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.postJobCommands = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 7:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->installedPath);
+ this->__isset.installedPath = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 8:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->monitorMode);
+ this->__isset.monitorMode = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_jobSubmissionDataID)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_resourceJobManager)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t GSISSHJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("GSISSHJobSubmission");
+
+ xfer += oprot->writeFieldBegin("jobSubmissionDataID", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->jobSubmissionDataID);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("resourceJobManager", ::apache::thrift::protocol::T_I32, 2);
+ xfer += oprot->writeI32((int32_t)this->resourceJobManager);
+ xfer += oprot->writeFieldEnd();
+
+ if (this->__isset.sshPort) {
+ xfer += oprot->writeFieldBegin("sshPort", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeI32(this->sshPort);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.exports) {
+ xfer += oprot->writeFieldBegin("exports", ::apache::thrift::protocol::T_SET, 4);
+ {
+ xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->exports.size()));
+ std::set<std::string> ::const_iterator _iter34;
+ for (_iter34 = this->exports.begin(); _iter34 != this->exports.end(); ++_iter34)
+ {
+ xfer += oprot->writeString((*_iter34));
+ }
+ xfer += oprot->writeSetEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.preJobCommands) {
+ xfer += oprot->writeFieldBegin("preJobCommands", ::apache::thrift::protocol::T_LIST, 5);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->preJobCommands.size()));
+ std::vector<std::string> ::const_iterator _iter35;
+ for (_iter35 = this->preJobCommands.begin(); _iter35 != this->preJobCommands.end(); ++_iter35)
+ {
+ xfer += oprot->writeString((*_iter35));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.postJobCommands) {
+ xfer += oprot->writeFieldBegin("postJobCommands", ::apache::thrift::protocol::T_LIST, 6);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->postJobCommands.size()));
+ std::vector<std::string> ::const_iterator _iter36;
+ for (_iter36 = this->postJobCommands.begin(); _iter36 != this->postJobCommands.end(); ++_iter36)
+ {
+ xfer += oprot->writeString((*_iter36));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.installedPath) {
+ xfer += oprot->writeFieldBegin("installedPath", ::apache::thrift::protocol::T_STRING, 7);
+ xfer += oprot->writeString(this->installedPath);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.monitorMode) {
+ xfer += oprot->writeFieldBegin("monitorMode", ::apache::thrift::protocol::T_STRING, 8);
+ xfer += oprot->writeString(this->monitorMode);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(GSISSHJobSubmission &a, GSISSHJobSubmission &b) {
+ using ::std::swap;
+ swap(a.jobSubmissionDataID, b.jobSubmissionDataID);
+ swap(a.resourceJobManager, b.resourceJobManager);
+ swap(a.sshPort, b.sshPort);
+ swap(a.exports, b.exports);
+ swap(a.preJobCommands, b.preJobCommands);
+ swap(a.postJobCommands, b.postJobCommands);
+ swap(a.installedPath, b.installedPath);
+ swap(a.monitorMode, b.monitorMode);
+ swap(a.__isset, b.__isset);
+}
+
+const char* ComputeResourceDescription::ascii_fingerprint = "A31E9EF4FF0C9ADE9027FD5C59A96555";
+const uint8_t ComputeResourceDescription::binary_fingerprint[16] = {0xA3,0x1E,0x9E,0xF4,0xFF,0x0C,0x9A,0xDE,0x90,0x27,0xFD,0x5C,0x59,0xA9,0x65,0x55};
+
+uint32_t ComputeResourceDescription::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_isEmpty = false;
+ bool isset_resourceId = false;
+ bool isset_hostName = false;
+ bool isset_jobSubmissionProtocols = false;
+ bool isset_dataMovementProtocols = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool(this->isEmpty);
+ isset_isEmpty = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->resourceId);
+ isset_resourceId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->hostName);
+ isset_hostName = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_SET) {
+ {
+ this->hostAliases.clear();
+ uint32_t _size37;
+ ::apache::thrift::protocol::TType _etype40;
+ xfer += iprot->readSetBegin(_etype40, _size37);
+ uint32_t _i41;
+ for (_i41 = 0; _i41 < _size37; ++_i41)
+ {
+ std::string _elem42;
+ xfer += iprot->readString(_elem42);
+ this->hostAliases.insert(_elem42);
+ }
+ xfer += iprot->readSetEnd();
+ }
+ this->__isset.hostAliases = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 5:
+ if (ftype == ::apache::thrift::protocol::T_SET) {
+ {
+ this->ipAddresses.clear();
+ uint32_t _size43;
+ ::apache::thrift::protocol::TType _etype46;
+ xfer += iprot->readSetBegin(_etype46, _size43);
+ uint32_t _i47;
+ for (_i47 = 0; _i47 < _size43; ++_i47)
+ {
+ std::string _elem48;
+ xfer += iprot->readString(_elem48);
+ this->ipAddresses.insert(_elem48);
+ }
+ xfer += iprot->readSetEnd();
+ }
+ this->__isset.ipAddresses = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 6:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->resourceDescription);
+ this->__isset.resourceDescription = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 8:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->preferredJobSubmissionProtocol);
+ this->__isset.preferredJobSubmissionProtocol = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 9:
+ if (ftype == ::apache::thrift::protocol::T_MAP) {
+ {
+ this->jobSubmissionProtocols.clear();
+ uint32_t _size49;
+ ::apache::thrift::protocol::TType _ktype50;
+ ::apache::thrift::protocol::TType _vtype51;
+ xfer += iprot->readMapBegin(_ktype50, _vtype51, _size49);
+ uint32_t _i53;
+ for (_i53 = 0; _i53 < _size49; ++_i53)
+ {
+ std::string _key54;
+ xfer += iprot->readString(_key54);
+ JobSubmissionProtocol::type& _val55 = this->jobSubmissionProtocols[_key54];
+ int32_t ecast56;
+ xfer += iprot->readI32(ecast56);
+ _val55 = (JobSubmissionProtocol::type)ecast56;
+ }
+ xfer += iprot->readMapEnd();
+ }
+ isset_jobSubmissionProtocols = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 10:
+ if (ftype == ::apache::thrift::protocol::T_MAP) {
+ {
+ this->dataMovementProtocols.clear();
+ uint32_t _size57;
+ ::apache::thrift::protocol::TType _ktype58;
+ ::apache::thrift::protocol::TType _vtype59;
+ xfer += iprot->readMapBegin(_ktype58, _vtype59, _size57);
+ uint32_t _i61;
+ for (_i61 = 0; _i61 < _size57; ++_i61)
+ {
+ std::string _key62;
+ xfer += iprot->readString(_key62);
+ DataMovementProtocol::type& _val63 = this->dataMovementProtocols[_key62];
+ int32_t ecast64;
+ xfer += iprot->readI32(ecast64);
+ _val63 = (DataMovementProtocol::type)ecast64;
+ }
+ xfer += iprot->readMapEnd();
+ }
+ isset_dataMovementProtocols = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_isEmpty)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_resourceId)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_hostName)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_jobSubmissionProtocols)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_dataMovementProtocols)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t ComputeResourceDescription::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("ComputeResourceDescription");
+
+ xfer += oprot->writeFieldBegin("isEmpty", ::apache::thrift::protocol::T_BOOL, 1);
+ xfer += oprot->writeBool(this->isEmpty);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("resourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->resourceId);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("hostName", ::apache::thrift::protocol::T_STRING, 3);
+ xfer += oprot->writeString(this->hostName);
+ xfer += oprot->writeFieldEnd();
+
+ if (this->__isset.hostAliases) {
+ xfer += oprot->writeFieldBegin("hostAliases", ::apache::thrift::protocol::T_SET, 4);
+ {
+ xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->hostAliases.size()));
+ std::set<std::string> ::const_iterator _iter65;
+ for (_iter65 = this->hostAliases.begin(); _iter65 != this->hostAliases.end(); ++_iter65)
+ {
+ xfer += oprot->writeString((*_iter65));
+ }
+ xfer += oprot->writeSetEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.ipAddresses) {
+ xfer += oprot->writeFieldBegin("ipAddresses", ::apache::thrift::protocol::T_SET, 5);
+ {
+ xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->ipAddresses.size()));
+ std::set<std::string> ::const_iterator _iter66;
+ for (_iter66 = this->ipAddresses.begin(); _iter66 != this->ipAddresses.end(); ++_iter66)
+ {
+ xfer += oprot->writeString((*_iter66));
+ }
+ xfer += oprot->writeSetEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.resourceDescription) {
+ xfer += oprot->writeFieldBegin("resourceDescription", ::apache::thrift::protocol::T_STRING, 6);
+ xfer += oprot->writeString(this->resourceDescription);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.preferredJobSubmissionProtocol) {
+ xfer += oprot->writeFieldBegin("preferredJobSubmissionProtocol", ::apache::thrift::protocol::T_STRING, 8);
+ xfer += oprot->writeString(this->preferredJobSubmissionProtocol);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldBegin("jobSubmissionProtocols", ::apache::thrift::protocol::T_MAP, 9);
+ {
+ xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->jobSubmissionProtocols.size()));
+ std::map<std::string, JobSubmissionProtocol::type> ::const_iterator _iter67;
+ for (_iter67 = this->jobSubmissionProtocols.begin(); _iter67 != this->jobSubmissionProtocols.end(); ++_iter67)
+ {
+ xfer += oprot->writeString(_iter67->first);
+ xfer += oprot->writeI32((int32_t)_iter67->second);
+ }
+ xfer += oprot->writeMapEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("dataMovementProtocols", ::apache::thrift::protocol::T_MAP, 10);
+ {
+ xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->dataMovementProtocols.size()));
+ std::map<std::string, DataMovementProtocol::type> ::const_iterator _iter68;
+ for (_iter68 = this->dataMovementProtocols.begin(); _iter68 != this->dataMovementProtocols.end(); ++_iter68)
+ {
+ xfer += oprot->writeString(_iter68->first);
+ xfer += oprot->writeI32((int32_t)_iter68->second);
+ }
+ xfer += oprot->writeMapEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(ComputeResourceDescription &a, ComputeResourceDescription &b) {
+ using ::std::swap;
+ swap(a.isEmpty, b.isEmpty);
+ swap(a.resourceId, b.resourceId);
+ swap(a.hostName, b.hostName);
+ swap(a.hostAliases, b.hostAliases);
+ swap(a.ipAddresses, b.ipAddresses);
+ swap(a.resourceDescription, b.resourceDescription);
+ swap(a.preferredJobSubmissionProtocol, b.preferredJobSubmissionProtocol);
+ swap(a.jobSubmissionProtocols, b.jobSubmissionProtocols);
+ swap(a.dataMovementProtocols, b.dataMovementProtocols);
+ swap(a.__isset, b.__isset);
+}
+
+
http://git-wip-us.apache.org/repos/asf/airavata/blob/0a002531/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_types.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_types.h
new file mode 100644
index 0000000..15e893f
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_types.h
@@ -0,0 +1,534 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.1)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#ifndef computeResourceModel_TYPES_H
+#define computeResourceModel_TYPES_H
+
+#include <thrift/Thrift.h>
+#include <thrift/TApplicationException.h>
+#include <thrift/protocol/TProtocol.h>
+#include <thrift/transport/TTransport.h>
+
+#include <thrift/cxxfunctional.h>
+
+
+
+
+struct ResourceJobManager {
+ enum type {
+ FORK = 0,
+ PBS = 1,
+ UGE = 2,
+ SLURM = 3
+ };
+};
+
+extern const std::map<int, const char*> _ResourceJobManager_VALUES_TO_NAMES;
+
+struct JobSubmissionProtocol {
+ enum type {
+ SSH = 0,
+ GSISSH = 1,
+ GRAM = 2,
+ UNICORE = 3
+ };
+};
+
+extern const std::map<int, const char*> _JobSubmissionProtocol_VALUES_TO_NAMES;
+
+struct DataMovementProtocol {
+ enum type {
+ SCP = 0,
+ SFTP = 1,
+ GridFTP = 2,
+ UNICORE_STORAGE_SERVICE = 3
+ };
+};
+
+extern const std::map<int, const char*> _DataMovementProtocol_VALUES_TO_NAMES;
+
+struct SecurityProtocol {
+ enum type {
+ USERNAME_PASSWORD = 0,
+ SSH_KEYS = 1,
+ GSI = 2,
+ KERBEROS = 3,
+ OAUTH = 4
+ };
+};
+
+extern const std::map<int, const char*> _SecurityProtocol_VALUES_TO_NAMES;
+
+typedef struct _SCPDataMovement__isset {
+ _SCPDataMovement__isset() : sshPort(true) {}
+ bool sshPort;
+} _SCPDataMovement__isset;
+
+class SCPDataMovement {
+ public:
+
+ static const char* ascii_fingerprint; // = "FEB6B2CD28861B4EED855CACA1FEF2CB";
+ static const uint8_t binary_fingerprint[16]; // = {0xFE,0xB6,0xB2,0xCD,0x28,0x86,0x1B,0x4E,0xED,0x85,0x5C,0xAC,0xA1,0xFE,0xF2,0xCB};
+
+ SCPDataMovement() : dataMovementDataID("DO_NOT_SET_AT_CLIENTS"), securityProtocol((SecurityProtocol::type)0), sshPort(22) {
+ }
+
+ virtual ~SCPDataMovement() throw() {}
+
+ std::string dataMovementDataID;
+ SecurityProtocol::type securityProtocol;
+ int32_t sshPort;
+
+ _SCPDataMovement__isset __isset;
+
+ void __set_dataMovementDataID(const std::string& val) {
+ dataMovementDataID = val;
+ }
+
+ void __set_securityProtocol(const SecurityProtocol::type val) {
+ securityProtocol = val;
+ }
+
+ void __set_sshPort(const int32_t val) {
+ sshPort = val;
+ __isset.sshPort = true;
+ }
+
+ bool operator == (const SCPDataMovement & rhs) const
+ {
+ if (!(dataMovementDataID == rhs.dataMovementDataID))
+ return false;
+ if (!(securityProtocol == rhs.securityProtocol))
+ return false;
+ if (__isset.sshPort != rhs.__isset.sshPort)
+ return false;
+ else if (__isset.sshPort && !(sshPort == rhs.sshPort))
+ return false;
+ return true;
+ }
+ bool operator != (const SCPDataMovement &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const SCPDataMovement & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(SCPDataMovement &a, SCPDataMovement &b);
+
+
+class GridFTPDataMovement {
+ public:
+
+ static const char* ascii_fingerprint; // = "790EE8B1D56A3B9B76C41DD063726E75";
+ static const uint8_t binary_fingerprint[16]; // = {0x79,0x0E,0xE8,0xB1,0xD5,0x6A,0x3B,0x9B,0x76,0xC4,0x1D,0xD0,0x63,0x72,0x6E,0x75};
+
+ GridFTPDataMovement() : dataMovementDataID("DO_NOT_SET_AT_CLIENTS"), securityProtocol((SecurityProtocol::type)0) {
+ }
+
+ virtual ~GridFTPDataMovement() throw() {}
+
+ std::string dataMovementDataID;
+ SecurityProtocol::type securityProtocol;
+ std::vector<std::string> gridFTPEndPoint;
+
+ void __set_dataMovementDataID(const std::string& val) {
+ dataMovementDataID = val;
+ }
+
+ void __set_securityProtocol(const SecurityProtocol::type val) {
+ securityProtocol = val;
+ }
+
+ void __set_gridFTPEndPoint(const std::vector<std::string> & val) {
+ gridFTPEndPoint = val;
+ }
+
+ bool operator == (const GridFTPDataMovement & rhs) const
+ {
+ if (!(dataMovementDataID == rhs.dataMovementDataID))
+ return false;
+ if (!(securityProtocol == rhs.securityProtocol))
+ return false;
+ if (!(gridFTPEndPoint == rhs.gridFTPEndPoint))
+ return false;
+ return true;
+ }
+ bool operator != (const GridFTPDataMovement &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const GridFTPDataMovement & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(GridFTPDataMovement &a, GridFTPDataMovement &b);
+
+typedef struct _SSHJobSubmission__isset {
+ _SSHJobSubmission__isset() : sshPort(true) {}
+ bool sshPort;
+} _SSHJobSubmission__isset;
+
+class SSHJobSubmission {
+ public:
+
+ static const char* ascii_fingerprint; // = "FEB6B2CD28861B4EED855CACA1FEF2CB";
+ static const uint8_t binary_fingerprint[16]; // = {0xFE,0xB6,0xB2,0xCD,0x28,0x86,0x1B,0x4E,0xED,0x85,0x5C,0xAC,0xA1,0xFE,0xF2,0xCB};
+
+ SSHJobSubmission() : jobSubmissionDataID("DO_NOT_SET_AT_CLIENTS"), resourceJobManager((ResourceJobManager::type)0), sshPort(22) {
+ }
+
+ virtual ~SSHJobSubmission() throw() {}
+
+ std::string jobSubmissionDataID;
+ ResourceJobManager::type resourceJobManager;
+ int32_t sshPort;
+
+ _SSHJobSubmission__isset __isset;
+
+ void __set_jobSubmissionDataID(const std::string& val) {
+ jobSubmissionDataID = val;
+ }
+
+ void __set_resourceJobManager(const ResourceJobManager::type val) {
+ resourceJobManager = val;
+ }
+
+ void __set_sshPort(const int32_t val) {
+ sshPort = val;
+ __isset.sshPort = true;
+ }
+
+ bool operator == (const SSHJobSubmission & rhs) const
+ {
+ if (!(jobSubmissionDataID == rhs.jobSubmissionDataID))
+ return false;
+ if (!(resourceJobManager == rhs.resourceJobManager))
+ return false;
+ if (__isset.sshPort != rhs.__isset.sshPort)
+ return false;
+ else if (__isset.sshPort && !(sshPort == rhs.sshPort))
+ return false;
+ return true;
+ }
+ bool operator != (const SSHJobSubmission &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const SSHJobSubmission & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(SSHJobSubmission &a, SSHJobSubmission &b);
+
+typedef struct _GlobusJobSubmission__isset {
+ _GlobusJobSubmission__isset() : globusGateKeeperEndPoint(false) {}
+ bool globusGateKeeperEndPoint;
+} _GlobusJobSubmission__isset;
+
+class GlobusJobSubmission {
+ public:
+
+ static const char* ascii_fingerprint; // = "DF4253F78D7B543C16FA461660D38A03";
+ static const uint8_t binary_fingerprint[16]; // = {0xDF,0x42,0x53,0xF7,0x8D,0x7B,0x54,0x3C,0x16,0xFA,0x46,0x16,0x60,0xD3,0x8A,0x03};
+
+ GlobusJobSubmission() : jobSubmissionDataID("DO_NOT_SET_AT_CLIENTS"), securityProtocol((SecurityProtocol::type)0), resourceJobManager((ResourceJobManager::type)0) {
+ }
+
+ virtual ~GlobusJobSubmission() throw() {}
+
+ std::string jobSubmissionDataID;
+ SecurityProtocol::type securityProtocol;
+ ResourceJobManager::type resourceJobManager;
+ std::vector<std::string> globusGateKeeperEndPoint;
+
+ _GlobusJobSubmission__isset __isset;
+
+ void __set_jobSubmissionDataID(const std::string& val) {
+ jobSubmissionDataID = val;
+ }
+
+ void __set_securityProtocol(const SecurityProtocol::type val) {
+ securityProtocol = val;
+ }
+
+ void __set_resourceJobManager(const ResourceJobManager::type val) {
+ resourceJobManager = val;
+ }
+
+ void __set_globusGateKeeperEndPoint(const std::vector<std::string> & val) {
+ globusGateKeeperEndPoint = val;
+ __isset.globusGateKeeperEndPoint = true;
+ }
+
+ bool operator == (const GlobusJobSubmission & rhs) const
+ {
+ if (!(jobSubmissionDataID == rhs.jobSubmissionDataID))
+ return false;
+ if (!(securityProtocol == rhs.securityProtocol))
+ return false;
+ if (!(resourceJobManager == rhs.resourceJobManager))
+ return false;
+ if (__isset.globusGateKeeperEndPoint != rhs.__isset.globusGateKeeperEndPoint)
+ return false;
+ else if (__isset.globusGateKeeperEndPoint && !(globusGateKeeperEndPoint == rhs.globusGateKeeperEndPoint))
+ return false;
+ return true;
+ }
+ bool operator != (const GlobusJobSubmission &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const GlobusJobSubmission & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(GlobusJobSubmission &a, GlobusJobSubmission &b);
+
+typedef struct _GSISSHJobSubmission__isset {
+ _GSISSHJobSubmission__isset() : sshPort(true), exports(false), preJobCommands(false), postJobCommands(false), installedPath(false), monitorMode(false) {}
+ bool sshPort;
+ bool exports;
+ bool preJobCommands;
+ bool postJobCommands;
+ bool installedPath;
+ bool monitorMode;
+} _GSISSHJobSubmission__isset;
+
+class GSISSHJobSubmission {
+ public:
+
+ static const char* ascii_fingerprint; // = "6969A7F145C4403B2F9081A498E933FD";
+ static const uint8_t binary_fingerprint[16]; // = {0x69,0x69,0xA7,0xF1,0x45,0xC4,0x40,0x3B,0x2F,0x90,0x81,0xA4,0x98,0xE9,0x33,0xFD};
+
+ GSISSHJobSubmission() : jobSubmissionDataID("DO_NOT_SET_AT_CLIENTS"), resourceJobManager((ResourceJobManager::type)0), sshPort(22), installedPath(), monitorMode() {
+ }
+
+ virtual ~GSISSHJobSubmission() throw() {}
+
+ std::string jobSubmissionDataID;
+ ResourceJobManager::type resourceJobManager;
+ int32_t sshPort;
+ std::set<std::string> exports;
+ std::vector<std::string> preJobCommands;
+ std::vector<std::string> postJobCommands;
+ std::string installedPath;
+ std::string monitorMode;
+
+ _GSISSHJobSubmission__isset __isset;
+
+ void __set_jobSubmissionDataID(const std::string& val) {
+ jobSubmissionDataID = val;
+ }
+
+ void __set_resourceJobManager(const ResourceJobManager::type val) {
+ resourceJobManager = val;
+ }
+
+ void __set_sshPort(const int32_t val) {
+ sshPort = val;
+ __isset.sshPort = true;
+ }
+
+ void __set_exports(const std::set<std::string> & val) {
+ exports = val;
+ __isset.exports = true;
+ }
+
+ void __set_preJobCommands(const std::vector<std::string> & val) {
+ preJobCommands = val;
+ __isset.preJobCommands = true;
+ }
+
+ void __set_postJobCommands(const std::vector<std::string> & val) {
+ postJobCommands = val;
+ __isset.postJobCommands = true;
+ }
+
+ void __set_installedPath(const std::string& val) {
+ installedPath = val;
+ __isset.installedPath = true;
+ }
+
+ void __set_monitorMode(const std::string& val) {
+ monitorMode = val;
+ __isset.monitorMode = true;
+ }
+
+ bool operator == (const GSISSHJobSubmission & rhs) const
+ {
+ if (!(jobSubmissionDataID == rhs.jobSubmissionDataID))
+ return false;
+ if (!(resourceJobManager == rhs.resourceJobManager))
+ return false;
+ if (__isset.sshPort != rhs.__isset.sshPort)
+ return false;
+ else if (__isset.sshPort && !(sshPort == rhs.sshPort))
+ return false;
+ if (__isset.exports != rhs.__isset.exports)
+ return false;
+ else if (__isset.exports && !(exports == rhs.exports))
+ return false;
+ if (__isset.preJobCommands != rhs.__isset.preJobCommands)
+ return false;
+ else if (__isset.preJobCommands && !(preJobCommands == rhs.preJobCommands))
+ return false;
+ if (__isset.postJobCommands != rhs.__isset.postJobCommands)
+ return false;
+ else if (__isset.postJobCommands && !(postJobCommands == rhs.postJobCommands))
+ return false;
+ if (__isset.installedPath != rhs.__isset.installedPath)
+ return false;
+ else if (__isset.installedPath && !(installedPath == rhs.installedPath))
+ return false;
+ if (__isset.monitorMode != rhs.__isset.monitorMode)
+ return false;
+ else if (__isset.monitorMode && !(monitorMode == rhs.monitorMode))
+ return false;
+ return true;
+ }
+ bool operator != (const GSISSHJobSubmission &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const GSISSHJobSubmission & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(GSISSHJobSubmission &a, GSISSHJobSubmission &b);
+
+typedef struct _ComputeResourceDescription__isset {
+ _ComputeResourceDescription__isset() : hostAliases(false), ipAddresses(false), resourceDescription(false), preferredJobSubmissionProtocol(false) {}
+ bool hostAliases;
+ bool ipAddresses;
+ bool resourceDescription;
+ bool preferredJobSubmissionProtocol;
+} _ComputeResourceDescription__isset;
+
+class ComputeResourceDescription {
+ public:
+
+ static const char* ascii_fingerprint; // = "A31E9EF4FF0C9ADE9027FD5C59A96555";
+ static const uint8_t binary_fingerprint[16]; // = {0xA3,0x1E,0x9E,0xF4,0xFF,0x0C,0x9A,0xDE,0x90,0x27,0xFD,0x5C,0x59,0xA9,0x65,0x55};
+
+ ComputeResourceDescription() : isEmpty(false), resourceId("DO_NOT_SET_AT_CLIENTS"), hostName(), resourceDescription(), preferredJobSubmissionProtocol() {
+ }
+
+ virtual ~ComputeResourceDescription() throw() {}
+
+ bool isEmpty;
+ std::string resourceId;
+ std::string hostName;
+ std::set<std::string> hostAliases;
+ std::set<std::string> ipAddresses;
+ std::string resourceDescription;
+ std::string preferredJobSubmissionProtocol;
+ std::map<std::string, JobSubmissionProtocol::type> jobSubmissionProtocols;
+ std::map<std::string, DataMovementProtocol::type> dataMovementProtocols;
+
+ _ComputeResourceDescription__isset __isset;
+
+ void __set_isEmpty(const bool val) {
+ isEmpty = val;
+ }
+
+ void __set_resourceId(const std::string& val) {
+ resourceId = val;
+ }
+
+ void __set_hostName(const std::string& val) {
+ hostName = val;
+ }
+
+ void __set_hostAliases(const std::set<std::string> & val) {
+ hostAliases = val;
+ __isset.hostAliases = true;
+ }
+
+ void __set_ipAddresses(const std::set<std::string> & val) {
+ ipAddresses = val;
+ __isset.ipAddresses = true;
+ }
+
+ void __set_resourceDescription(const std::string& val) {
+ resourceDescription = val;
+ __isset.resourceDescription = true;
+ }
+
+ void __set_preferredJobSubmissionProtocol(const std::string& val) {
+ preferredJobSubmissionProtocol = val;
+ __isset.preferredJobSubmissionProtocol = true;
+ }
+
+ void __set_jobSubmissionProtocols(const std::map<std::string, JobSubmissionProtocol::type> & val) {
+ jobSubmissionProtocols = val;
+ }
+
+ void __set_dataMovementProtocols(const std::map<std::string, DataMovementProtocol::type> & val) {
+ dataMovementProtocols = val;
+ }
+
+ bool operator == (const ComputeResourceDescription & rhs) const
+ {
+ if (!(isEmpty == rhs.isEmpty))
+ return false;
+ if (!(resourceId == rhs.resourceId))
+ return false;
+ if (!(hostName == rhs.hostName))
+ return false;
+ if (__isset.hostAliases != rhs.__isset.hostAliases)
+ return false;
+ else if (__isset.hostAliases && !(hostAliases == rhs.hostAliases))
+ return false;
+ if (__isset.ipAddresses != rhs.__isset.ipAddresses)
+ return false;
+ else if (__isset.ipAddresses && !(ipAddresses == rhs.ipAddresses))
+ return false;
+ if (__isset.resourceDescription != rhs.__isset.resourceDescription)
+ return false;
+ else if (__isset.resourceDescription && !(resourceDescription == rhs.resourceDescription))
+ return false;
+ if (__isset.preferredJobSubmissionProtocol != rhs.__isset.preferredJobSubmissionProtocol)
+ return false;
+ else if (__isset.preferredJobSubmissionProtocol && !(preferredJobSubmissionProtocol == rhs.preferredJobSubmissionProtocol))
+ return false;
+ if (!(jobSubmissionProtocols == rhs.jobSubmissionProtocols))
+ return false;
+ if (!(dataMovementProtocols == rhs.dataMovementProtocols))
+ return false;
+ return true;
+ }
+ bool operator != (const ComputeResourceDescription &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ComputeResourceDescription & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(ComputeResourceDescription &a, ComputeResourceDescription &b);
+
+
+
+#endif
[3/3] git commit: Updating ComputeResource Namespace to align with
application descrrptions - AIRAVATA-1203
Posted by sm...@apache.org.
Updating ComputeResource Namespace to align with application descrrptions - AIRAVATA-1203
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/0a002531
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/0a002531
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/0a002531
Branch: refs/heads/master
Commit: 0a002531b7de367ebaa90b14a16f1859acde1b83
Parents: 169e6f9
Author: Suresh Marru <sm...@apache.org>
Authored: Thu Jul 3 10:15:04 2014 -0400
Committer: Suresh Marru <sm...@apache.org>
Committed: Thu Jul 3 10:15:04 2014 -0400
----------------------------------------------------------------------
.../lib/computeHostModel_constants.cpp | 19 -
.../resources/lib/computeHostModel_constants.h | 25 -
.../resources/lib/computeHostModel_types.cpp | 1025 --------------
.../main/resources/lib/computeHostModel_types.h | 534 --------
.../lib/computeResourceModel_constants.cpp | 19 +
.../lib/computeResourceModel_constants.h | 25 +
.../lib/computeResourceModel_types.cpp | 1025 ++++++++++++++
.../resources/lib/computeResourceModel_types.h | 534 ++++++++
.../lib/Airavata/Model/ComputeHost/Types.php | 1262 ------------------
9 files changed, 1603 insertions(+), 2865 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/0a002531/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_constants.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_constants.cpp
deleted file mode 100644
index ab08041..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_constants.cpp
+++ /dev/null
@@ -1,19 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.9.1)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-#include "computeHostModel_constants.h"
-
-
-
-const computeHostModelConstants g_computeHostModel_constants;
-
-computeHostModelConstants::computeHostModelConstants() {
- DEFAULT_ID = "DO_NOT_SET_AT_CLIENTS";
-
-}
-
-
-
http://git-wip-us.apache.org/repos/asf/airavata/blob/0a002531/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_constants.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_constants.h
deleted file mode 100644
index bcf9989..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_constants.h
+++ /dev/null
@@ -1,25 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.9.1)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-#ifndef computeHostModel_CONSTANTS_H
-#define computeHostModel_CONSTANTS_H
-
-#include "computeHostModel_types.h"
-
-
-
-class computeHostModelConstants {
- public:
- computeHostModelConstants();
-
- std::string DEFAULT_ID;
-};
-
-extern const computeHostModelConstants g_computeHostModel_constants;
-
-
-
-#endif
http://git-wip-us.apache.org/repos/asf/airavata/blob/0a002531/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_types.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_types.cpp
deleted file mode 100644
index 05b3092..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_types.cpp
+++ /dev/null
@@ -1,1025 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.9.1)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-#include "computeHostModel_types.h"
-
-#include <algorithm>
-
-
-
-int _kResourceJobManagerValues[] = {
- ResourceJobManager::FORK,
- ResourceJobManager::PBS,
- ResourceJobManager::UGE,
- ResourceJobManager::SLURM
-};
-const char* _kResourceJobManagerNames[] = {
- "FORK",
- "PBS",
- "UGE",
- "SLURM"
-};
-const std::map<int, const char*> _ResourceJobManager_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4, _kResourceJobManagerValues, _kResourceJobManagerNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kJobSubmissionProtocolValues[] = {
- JobSubmissionProtocol::SSH,
- JobSubmissionProtocol::GSISSH,
- JobSubmissionProtocol::GRAM,
- JobSubmissionProtocol::UNICORE
-};
-const char* _kJobSubmissionProtocolNames[] = {
- "SSH",
- "GSISSH",
- "GRAM",
- "UNICORE"
-};
-const std::map<int, const char*> _JobSubmissionProtocol_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4, _kJobSubmissionProtocolValues, _kJobSubmissionProtocolNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kDataMovementProtocolValues[] = {
- DataMovementProtocol::SCP,
- DataMovementProtocol::SFTP,
- DataMovementProtocol::GridFTP,
- DataMovementProtocol::UNICORE_STORAGE_SERVICE
-};
-const char* _kDataMovementProtocolNames[] = {
- "SCP",
- "SFTP",
- "GridFTP",
- "UNICORE_STORAGE_SERVICE"
-};
-const std::map<int, const char*> _DataMovementProtocol_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4, _kDataMovementProtocolValues, _kDataMovementProtocolNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kSecurityProtocolValues[] = {
- SecurityProtocol::USERNAME_PASSWORD,
- SecurityProtocol::SSH_KEYS,
- SecurityProtocol::GSI,
- SecurityProtocol::KERBEROS,
- SecurityProtocol::OAUTH
-};
-const char* _kSecurityProtocolNames[] = {
- "USERNAME_PASSWORD",
- "SSH_KEYS",
- "GSI",
- "KERBEROS",
- "OAUTH"
-};
-const std::map<int, const char*> _SecurityProtocol_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(5, _kSecurityProtocolValues, _kSecurityProtocolNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-const char* SCPDataMovement::ascii_fingerprint = "FEB6B2CD28861B4EED855CACA1FEF2CB";
-const uint8_t SCPDataMovement::binary_fingerprint[16] = {0xFE,0xB6,0xB2,0xCD,0x28,0x86,0x1B,0x4E,0xED,0x85,0x5C,0xAC,0xA1,0xFE,0xF2,0xCB};
-
-uint32_t SCPDataMovement::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_dataMovementDataID = false;
- bool isset_securityProtocol = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->dataMovementDataID);
- isset_dataMovementDataID = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast0;
- xfer += iprot->readI32(ecast0);
- this->securityProtocol = (SecurityProtocol::type)ecast0;
- isset_securityProtocol = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->sshPort);
- this->__isset.sshPort = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_dataMovementDataID)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_securityProtocol)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t SCPDataMovement::write(::apache::thrift::protocol::TProtocol* oprot) const {
- uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("SCPDataMovement");
-
- xfer += oprot->writeFieldBegin("dataMovementDataID", ::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->dataMovementDataID);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("securityProtocol", ::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->securityProtocol);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.sshPort) {
- xfer += oprot->writeFieldBegin("sshPort", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->sshPort);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(SCPDataMovement &a, SCPDataMovement &b) {
- using ::std::swap;
- swap(a.dataMovementDataID, b.dataMovementDataID);
- swap(a.securityProtocol, b.securityProtocol);
- swap(a.sshPort, b.sshPort);
- swap(a.__isset, b.__isset);
-}
-
-const char* GridFTPDataMovement::ascii_fingerprint = "790EE8B1D56A3B9B76C41DD063726E75";
-const uint8_t GridFTPDataMovement::binary_fingerprint[16] = {0x79,0x0E,0xE8,0xB1,0xD5,0x6A,0x3B,0x9B,0x76,0xC4,0x1D,0xD0,0x63,0x72,0x6E,0x75};
-
-uint32_t GridFTPDataMovement::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_dataMovementDataID = false;
- bool isset_securityProtocol = false;
- bool isset_gridFTPEndPoint = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->dataMovementDataID);
- isset_dataMovementDataID = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast1;
- xfer += iprot->readI32(ecast1);
- this->securityProtocol = (SecurityProtocol::type)ecast1;
- isset_securityProtocol = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->gridFTPEndPoint.clear();
- uint32_t _size2;
- ::apache::thrift::protocol::TType _etype5;
- xfer += iprot->readListBegin(_etype5, _size2);
- this->gridFTPEndPoint.resize(_size2);
- uint32_t _i6;
- for (_i6 = 0; _i6 < _size2; ++_i6)
- {
- xfer += iprot->readString(this->gridFTPEndPoint[_i6]);
- }
- xfer += iprot->readListEnd();
- }
- isset_gridFTPEndPoint = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_dataMovementDataID)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_securityProtocol)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_gridFTPEndPoint)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t GridFTPDataMovement::write(::apache::thrift::protocol::TProtocol* oprot) const {
- uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("GridFTPDataMovement");
-
- xfer += oprot->writeFieldBegin("dataMovementDataID", ::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->dataMovementDataID);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("securityProtocol", ::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->securityProtocol);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("gridFTPEndPoint", ::apache::thrift::protocol::T_LIST, 3);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->gridFTPEndPoint.size()));
- std::vector<std::string> ::const_iterator _iter7;
- for (_iter7 = this->gridFTPEndPoint.begin(); _iter7 != this->gridFTPEndPoint.end(); ++_iter7)
- {
- xfer += oprot->writeString((*_iter7));
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(GridFTPDataMovement &a, GridFTPDataMovement &b) {
- using ::std::swap;
- swap(a.dataMovementDataID, b.dataMovementDataID);
- swap(a.securityProtocol, b.securityProtocol);
- swap(a.gridFTPEndPoint, b.gridFTPEndPoint);
-}
-
-const char* SSHJobSubmission::ascii_fingerprint = "FEB6B2CD28861B4EED855CACA1FEF2CB";
-const uint8_t SSHJobSubmission::binary_fingerprint[16] = {0xFE,0xB6,0xB2,0xCD,0x28,0x86,0x1B,0x4E,0xED,0x85,0x5C,0xAC,0xA1,0xFE,0xF2,0xCB};
-
-uint32_t SSHJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_jobSubmissionDataID = false;
- bool isset_resourceJobManager = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->jobSubmissionDataID);
- isset_jobSubmissionDataID = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast8;
- xfer += iprot->readI32(ecast8);
- this->resourceJobManager = (ResourceJobManager::type)ecast8;
- isset_resourceJobManager = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->sshPort);
- this->__isset.sshPort = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_jobSubmissionDataID)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_resourceJobManager)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t SSHJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot) const {
- uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("SSHJobSubmission");
-
- xfer += oprot->writeFieldBegin("jobSubmissionDataID", ::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->jobSubmissionDataID);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("resourceJobManager", ::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->resourceJobManager);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.sshPort) {
- xfer += oprot->writeFieldBegin("sshPort", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->sshPort);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(SSHJobSubmission &a, SSHJobSubmission &b) {
- using ::std::swap;
- swap(a.jobSubmissionDataID, b.jobSubmissionDataID);
- swap(a.resourceJobManager, b.resourceJobManager);
- swap(a.sshPort, b.sshPort);
- swap(a.__isset, b.__isset);
-}
-
-const char* GlobusJobSubmission::ascii_fingerprint = "DF4253F78D7B543C16FA461660D38A03";
-const uint8_t GlobusJobSubmission::binary_fingerprint[16] = {0xDF,0x42,0x53,0xF7,0x8D,0x7B,0x54,0x3C,0x16,0xFA,0x46,0x16,0x60,0xD3,0x8A,0x03};
-
-uint32_t GlobusJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_jobSubmissionDataID = false;
- bool isset_securityProtocol = false;
- bool isset_resourceJobManager = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->jobSubmissionDataID);
- isset_jobSubmissionDataID = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast9;
- xfer += iprot->readI32(ecast9);
- this->securityProtocol = (SecurityProtocol::type)ecast9;
- isset_securityProtocol = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast10;
- xfer += iprot->readI32(ecast10);
- this->resourceJobManager = (ResourceJobManager::type)ecast10;
- isset_resourceJobManager = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->globusGateKeeperEndPoint.clear();
- uint32_t _size11;
- ::apache::thrift::protocol::TType _etype14;
- xfer += iprot->readListBegin(_etype14, _size11);
- this->globusGateKeeperEndPoint.resize(_size11);
- uint32_t _i15;
- for (_i15 = 0; _i15 < _size11; ++_i15)
- {
- xfer += iprot->readString(this->globusGateKeeperEndPoint[_i15]);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.globusGateKeeperEndPoint = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_jobSubmissionDataID)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_securityProtocol)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_resourceJobManager)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t GlobusJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot) const {
- uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("GlobusJobSubmission");
-
- xfer += oprot->writeFieldBegin("jobSubmissionDataID", ::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->jobSubmissionDataID);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("securityProtocol", ::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->securityProtocol);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("resourceJobManager", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32((int32_t)this->resourceJobManager);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.globusGateKeeperEndPoint) {
- xfer += oprot->writeFieldBegin("globusGateKeeperEndPoint", ::apache::thrift::protocol::T_LIST, 4);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->globusGateKeeperEndPoint.size()));
- std::vector<std::string> ::const_iterator _iter16;
- for (_iter16 = this->globusGateKeeperEndPoint.begin(); _iter16 != this->globusGateKeeperEndPoint.end(); ++_iter16)
- {
- xfer += oprot->writeString((*_iter16));
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(GlobusJobSubmission &a, GlobusJobSubmission &b) {
- using ::std::swap;
- swap(a.jobSubmissionDataID, b.jobSubmissionDataID);
- swap(a.securityProtocol, b.securityProtocol);
- swap(a.resourceJobManager, b.resourceJobManager);
- swap(a.globusGateKeeperEndPoint, b.globusGateKeeperEndPoint);
- swap(a.__isset, b.__isset);
-}
-
-const char* GSISSHJobSubmission::ascii_fingerprint = "6969A7F145C4403B2F9081A498E933FD";
-const uint8_t GSISSHJobSubmission::binary_fingerprint[16] = {0x69,0x69,0xA7,0xF1,0x45,0xC4,0x40,0x3B,0x2F,0x90,0x81,0xA4,0x98,0xE9,0x33,0xFD};
-
-uint32_t GSISSHJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_jobSubmissionDataID = false;
- bool isset_resourceJobManager = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->jobSubmissionDataID);
- isset_jobSubmissionDataID = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast17;
- xfer += iprot->readI32(ecast17);
- this->resourceJobManager = (ResourceJobManager::type)ecast17;
- isset_resourceJobManager = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->sshPort);
- this->__isset.sshPort = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_SET) {
- {
- this->exports.clear();
- uint32_t _size18;
- ::apache::thrift::protocol::TType _etype21;
- xfer += iprot->readSetBegin(_etype21, _size18);
- uint32_t _i22;
- for (_i22 = 0; _i22 < _size18; ++_i22)
- {
- std::string _elem23;
- xfer += iprot->readString(_elem23);
- this->exports.insert(_elem23);
- }
- xfer += iprot->readSetEnd();
- }
- this->__isset.exports = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->preJobCommands.clear();
- uint32_t _size24;
- ::apache::thrift::protocol::TType _etype27;
- xfer += iprot->readListBegin(_etype27, _size24);
- this->preJobCommands.resize(_size24);
- uint32_t _i28;
- for (_i28 = 0; _i28 < _size24; ++_i28)
- {
- xfer += iprot->readString(this->preJobCommands[_i28]);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.preJobCommands = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->postJobCommands.clear();
- uint32_t _size29;
- ::apache::thrift::protocol::TType _etype32;
- xfer += iprot->readListBegin(_etype32, _size29);
- this->postJobCommands.resize(_size29);
- uint32_t _i33;
- for (_i33 = 0; _i33 < _size29; ++_i33)
- {
- xfer += iprot->readString(this->postJobCommands[_i33]);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.postJobCommands = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 7:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->installedPath);
- this->__isset.installedPath = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 8:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->monitorMode);
- this->__isset.monitorMode = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_jobSubmissionDataID)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_resourceJobManager)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t GSISSHJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot) const {
- uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("GSISSHJobSubmission");
-
- xfer += oprot->writeFieldBegin("jobSubmissionDataID", ::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->jobSubmissionDataID);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("resourceJobManager", ::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->resourceJobManager);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.sshPort) {
- xfer += oprot->writeFieldBegin("sshPort", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->sshPort);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.exports) {
- xfer += oprot->writeFieldBegin("exports", ::apache::thrift::protocol::T_SET, 4);
- {
- xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->exports.size()));
- std::set<std::string> ::const_iterator _iter34;
- for (_iter34 = this->exports.begin(); _iter34 != this->exports.end(); ++_iter34)
- {
- xfer += oprot->writeString((*_iter34));
- }
- xfer += oprot->writeSetEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.preJobCommands) {
- xfer += oprot->writeFieldBegin("preJobCommands", ::apache::thrift::protocol::T_LIST, 5);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->preJobCommands.size()));
- std::vector<std::string> ::const_iterator _iter35;
- for (_iter35 = this->preJobCommands.begin(); _iter35 != this->preJobCommands.end(); ++_iter35)
- {
- xfer += oprot->writeString((*_iter35));
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.postJobCommands) {
- xfer += oprot->writeFieldBegin("postJobCommands", ::apache::thrift::protocol::T_LIST, 6);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->postJobCommands.size()));
- std::vector<std::string> ::const_iterator _iter36;
- for (_iter36 = this->postJobCommands.begin(); _iter36 != this->postJobCommands.end(); ++_iter36)
- {
- xfer += oprot->writeString((*_iter36));
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.installedPath) {
- xfer += oprot->writeFieldBegin("installedPath", ::apache::thrift::protocol::T_STRING, 7);
- xfer += oprot->writeString(this->installedPath);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.monitorMode) {
- xfer += oprot->writeFieldBegin("monitorMode", ::apache::thrift::protocol::T_STRING, 8);
- xfer += oprot->writeString(this->monitorMode);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(GSISSHJobSubmission &a, GSISSHJobSubmission &b) {
- using ::std::swap;
- swap(a.jobSubmissionDataID, b.jobSubmissionDataID);
- swap(a.resourceJobManager, b.resourceJobManager);
- swap(a.sshPort, b.sshPort);
- swap(a.exports, b.exports);
- swap(a.preJobCommands, b.preJobCommands);
- swap(a.postJobCommands, b.postJobCommands);
- swap(a.installedPath, b.installedPath);
- swap(a.monitorMode, b.monitorMode);
- swap(a.__isset, b.__isset);
-}
-
-const char* ComputeResourceDescription::ascii_fingerprint = "A31E9EF4FF0C9ADE9027FD5C59A96555";
-const uint8_t ComputeResourceDescription::binary_fingerprint[16] = {0xA3,0x1E,0x9E,0xF4,0xFF,0x0C,0x9A,0xDE,0x90,0x27,0xFD,0x5C,0x59,0xA9,0x65,0x55};
-
-uint32_t ComputeResourceDescription::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_isEmpty = false;
- bool isset_resourceId = false;
- bool isset_hostName = false;
- bool isset_jobSubmissionProtocols = false;
- bool isset_dataMovementProtocols = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->isEmpty);
- isset_isEmpty = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->resourceId);
- isset_resourceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->hostName);
- isset_hostName = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_SET) {
- {
- this->hostAliases.clear();
- uint32_t _size37;
- ::apache::thrift::protocol::TType _etype40;
- xfer += iprot->readSetBegin(_etype40, _size37);
- uint32_t _i41;
- for (_i41 = 0; _i41 < _size37; ++_i41)
- {
- std::string _elem42;
- xfer += iprot->readString(_elem42);
- this->hostAliases.insert(_elem42);
- }
- xfer += iprot->readSetEnd();
- }
- this->__isset.hostAliases = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_SET) {
- {
- this->ipAddresses.clear();
- uint32_t _size43;
- ::apache::thrift::protocol::TType _etype46;
- xfer += iprot->readSetBegin(_etype46, _size43);
- uint32_t _i47;
- for (_i47 = 0; _i47 < _size43; ++_i47)
- {
- std::string _elem48;
- xfer += iprot->readString(_elem48);
- this->ipAddresses.insert(_elem48);
- }
- xfer += iprot->readSetEnd();
- }
- this->__isset.ipAddresses = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->resourceDescription);
- this->__isset.resourceDescription = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 8:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->preferredJobSubmissionProtocol);
- this->__isset.preferredJobSubmissionProtocol = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 9:
- if (ftype == ::apache::thrift::protocol::T_MAP) {
- {
- this->jobSubmissionProtocols.clear();
- uint32_t _size49;
- ::apache::thrift::protocol::TType _ktype50;
- ::apache::thrift::protocol::TType _vtype51;
- xfer += iprot->readMapBegin(_ktype50, _vtype51, _size49);
- uint32_t _i53;
- for (_i53 = 0; _i53 < _size49; ++_i53)
- {
- std::string _key54;
- xfer += iprot->readString(_key54);
- JobSubmissionProtocol::type& _val55 = this->jobSubmissionProtocols[_key54];
- int32_t ecast56;
- xfer += iprot->readI32(ecast56);
- _val55 = (JobSubmissionProtocol::type)ecast56;
- }
- xfer += iprot->readMapEnd();
- }
- isset_jobSubmissionProtocols = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 10:
- if (ftype == ::apache::thrift::protocol::T_MAP) {
- {
- this->dataMovementProtocols.clear();
- uint32_t _size57;
- ::apache::thrift::protocol::TType _ktype58;
- ::apache::thrift::protocol::TType _vtype59;
- xfer += iprot->readMapBegin(_ktype58, _vtype59, _size57);
- uint32_t _i61;
- for (_i61 = 0; _i61 < _size57; ++_i61)
- {
- std::string _key62;
- xfer += iprot->readString(_key62);
- DataMovementProtocol::type& _val63 = this->dataMovementProtocols[_key62];
- int32_t ecast64;
- xfer += iprot->readI32(ecast64);
- _val63 = (DataMovementProtocol::type)ecast64;
- }
- xfer += iprot->readMapEnd();
- }
- isset_dataMovementProtocols = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_isEmpty)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_resourceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_hostName)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_jobSubmissionProtocols)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_dataMovementProtocols)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t ComputeResourceDescription::write(::apache::thrift::protocol::TProtocol* oprot) const {
- uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("ComputeResourceDescription");
-
- xfer += oprot->writeFieldBegin("isEmpty", ::apache::thrift::protocol::T_BOOL, 1);
- xfer += oprot->writeBool(this->isEmpty);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("resourceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->resourceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("hostName", ::apache::thrift::protocol::T_STRING, 3);
- xfer += oprot->writeString(this->hostName);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.hostAliases) {
- xfer += oprot->writeFieldBegin("hostAliases", ::apache::thrift::protocol::T_SET, 4);
- {
- xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->hostAliases.size()));
- std::set<std::string> ::const_iterator _iter65;
- for (_iter65 = this->hostAliases.begin(); _iter65 != this->hostAliases.end(); ++_iter65)
- {
- xfer += oprot->writeString((*_iter65));
- }
- xfer += oprot->writeSetEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.ipAddresses) {
- xfer += oprot->writeFieldBegin("ipAddresses", ::apache::thrift::protocol::T_SET, 5);
- {
- xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->ipAddresses.size()));
- std::set<std::string> ::const_iterator _iter66;
- for (_iter66 = this->ipAddresses.begin(); _iter66 != this->ipAddresses.end(); ++_iter66)
- {
- xfer += oprot->writeString((*_iter66));
- }
- xfer += oprot->writeSetEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.resourceDescription) {
- xfer += oprot->writeFieldBegin("resourceDescription", ::apache::thrift::protocol::T_STRING, 6);
- xfer += oprot->writeString(this->resourceDescription);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.preferredJobSubmissionProtocol) {
- xfer += oprot->writeFieldBegin("preferredJobSubmissionProtocol", ::apache::thrift::protocol::T_STRING, 8);
- xfer += oprot->writeString(this->preferredJobSubmissionProtocol);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldBegin("jobSubmissionProtocols", ::apache::thrift::protocol::T_MAP, 9);
- {
- xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->jobSubmissionProtocols.size()));
- std::map<std::string, JobSubmissionProtocol::type> ::const_iterator _iter67;
- for (_iter67 = this->jobSubmissionProtocols.begin(); _iter67 != this->jobSubmissionProtocols.end(); ++_iter67)
- {
- xfer += oprot->writeString(_iter67->first);
- xfer += oprot->writeI32((int32_t)_iter67->second);
- }
- xfer += oprot->writeMapEnd();
- }
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("dataMovementProtocols", ::apache::thrift::protocol::T_MAP, 10);
- {
- xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->dataMovementProtocols.size()));
- std::map<std::string, DataMovementProtocol::type> ::const_iterator _iter68;
- for (_iter68 = this->dataMovementProtocols.begin(); _iter68 != this->dataMovementProtocols.end(); ++_iter68)
- {
- xfer += oprot->writeString(_iter68->first);
- xfer += oprot->writeI32((int32_t)_iter68->second);
- }
- xfer += oprot->writeMapEnd();
- }
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(ComputeResourceDescription &a, ComputeResourceDescription &b) {
- using ::std::swap;
- swap(a.isEmpty, b.isEmpty);
- swap(a.resourceId, b.resourceId);
- swap(a.hostName, b.hostName);
- swap(a.hostAliases, b.hostAliases);
- swap(a.ipAddresses, b.ipAddresses);
- swap(a.resourceDescription, b.resourceDescription);
- swap(a.preferredJobSubmissionProtocol, b.preferredJobSubmissionProtocol);
- swap(a.jobSubmissionProtocols, b.jobSubmissionProtocols);
- swap(a.dataMovementProtocols, b.dataMovementProtocols);
- swap(a.__isset, b.__isset);
-}
-
-
http://git-wip-us.apache.org/repos/asf/airavata/blob/0a002531/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_types.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_types.h
deleted file mode 100644
index 2892ebf..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeHostModel_types.h
+++ /dev/null
@@ -1,534 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.9.1)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-#ifndef computeHostModel_TYPES_H
-#define computeHostModel_TYPES_H
-
-#include <thrift/Thrift.h>
-#include <thrift/TApplicationException.h>
-#include <thrift/protocol/TProtocol.h>
-#include <thrift/transport/TTransport.h>
-
-#include <thrift/cxxfunctional.h>
-
-
-
-
-struct ResourceJobManager {
- enum type {
- FORK = 0,
- PBS = 1,
- UGE = 2,
- SLURM = 3
- };
-};
-
-extern const std::map<int, const char*> _ResourceJobManager_VALUES_TO_NAMES;
-
-struct JobSubmissionProtocol {
- enum type {
- SSH = 0,
- GSISSH = 1,
- GRAM = 2,
- UNICORE = 3
- };
-};
-
-extern const std::map<int, const char*> _JobSubmissionProtocol_VALUES_TO_NAMES;
-
-struct DataMovementProtocol {
- enum type {
- SCP = 0,
- SFTP = 1,
- GridFTP = 2,
- UNICORE_STORAGE_SERVICE = 3
- };
-};
-
-extern const std::map<int, const char*> _DataMovementProtocol_VALUES_TO_NAMES;
-
-struct SecurityProtocol {
- enum type {
- USERNAME_PASSWORD = 0,
- SSH_KEYS = 1,
- GSI = 2,
- KERBEROS = 3,
- OAUTH = 4
- };
-};
-
-extern const std::map<int, const char*> _SecurityProtocol_VALUES_TO_NAMES;
-
-typedef struct _SCPDataMovement__isset {
- _SCPDataMovement__isset() : sshPort(true) {}
- bool sshPort;
-} _SCPDataMovement__isset;
-
-class SCPDataMovement {
- public:
-
- static const char* ascii_fingerprint; // = "FEB6B2CD28861B4EED855CACA1FEF2CB";
- static const uint8_t binary_fingerprint[16]; // = {0xFE,0xB6,0xB2,0xCD,0x28,0x86,0x1B,0x4E,0xED,0x85,0x5C,0xAC,0xA1,0xFE,0xF2,0xCB};
-
- SCPDataMovement() : dataMovementDataID("DO_NOT_SET_AT_CLIENTS"), securityProtocol((SecurityProtocol::type)0), sshPort(22) {
- }
-
- virtual ~SCPDataMovement() throw() {}
-
- std::string dataMovementDataID;
- SecurityProtocol::type securityProtocol;
- int32_t sshPort;
-
- _SCPDataMovement__isset __isset;
-
- void __set_dataMovementDataID(const std::string& val) {
- dataMovementDataID = val;
- }
-
- void __set_securityProtocol(const SecurityProtocol::type val) {
- securityProtocol = val;
- }
-
- void __set_sshPort(const int32_t val) {
- sshPort = val;
- __isset.sshPort = true;
- }
-
- bool operator == (const SCPDataMovement & rhs) const
- {
- if (!(dataMovementDataID == rhs.dataMovementDataID))
- return false;
- if (!(securityProtocol == rhs.securityProtocol))
- return false;
- if (__isset.sshPort != rhs.__isset.sshPort)
- return false;
- else if (__isset.sshPort && !(sshPort == rhs.sshPort))
- return false;
- return true;
- }
- bool operator != (const SCPDataMovement &rhs) const {
- return !(*this == rhs);
- }
-
- bool operator < (const SCPDataMovement & ) const;
-
- uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
- uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
-
-};
-
-void swap(SCPDataMovement &a, SCPDataMovement &b);
-
-
-class GridFTPDataMovement {
- public:
-
- static const char* ascii_fingerprint; // = "790EE8B1D56A3B9B76C41DD063726E75";
- static const uint8_t binary_fingerprint[16]; // = {0x79,0x0E,0xE8,0xB1,0xD5,0x6A,0x3B,0x9B,0x76,0xC4,0x1D,0xD0,0x63,0x72,0x6E,0x75};
-
- GridFTPDataMovement() : dataMovementDataID("DO_NOT_SET_AT_CLIENTS"), securityProtocol((SecurityProtocol::type)0) {
- }
-
- virtual ~GridFTPDataMovement() throw() {}
-
- std::string dataMovementDataID;
- SecurityProtocol::type securityProtocol;
- std::vector<std::string> gridFTPEndPoint;
-
- void __set_dataMovementDataID(const std::string& val) {
- dataMovementDataID = val;
- }
-
- void __set_securityProtocol(const SecurityProtocol::type val) {
- securityProtocol = val;
- }
-
- void __set_gridFTPEndPoint(const std::vector<std::string> & val) {
- gridFTPEndPoint = val;
- }
-
- bool operator == (const GridFTPDataMovement & rhs) const
- {
- if (!(dataMovementDataID == rhs.dataMovementDataID))
- return false;
- if (!(securityProtocol == rhs.securityProtocol))
- return false;
- if (!(gridFTPEndPoint == rhs.gridFTPEndPoint))
- return false;
- return true;
- }
- bool operator != (const GridFTPDataMovement &rhs) const {
- return !(*this == rhs);
- }
-
- bool operator < (const GridFTPDataMovement & ) const;
-
- uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
- uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
-
-};
-
-void swap(GridFTPDataMovement &a, GridFTPDataMovement &b);
-
-typedef struct _SSHJobSubmission__isset {
- _SSHJobSubmission__isset() : sshPort(true) {}
- bool sshPort;
-} _SSHJobSubmission__isset;
-
-class SSHJobSubmission {
- public:
-
- static const char* ascii_fingerprint; // = "FEB6B2CD28861B4EED855CACA1FEF2CB";
- static const uint8_t binary_fingerprint[16]; // = {0xFE,0xB6,0xB2,0xCD,0x28,0x86,0x1B,0x4E,0xED,0x85,0x5C,0xAC,0xA1,0xFE,0xF2,0xCB};
-
- SSHJobSubmission() : jobSubmissionDataID("DO_NOT_SET_AT_CLIENTS"), resourceJobManager((ResourceJobManager::type)0), sshPort(22) {
- }
-
- virtual ~SSHJobSubmission() throw() {}
-
- std::string jobSubmissionDataID;
- ResourceJobManager::type resourceJobManager;
- int32_t sshPort;
-
- _SSHJobSubmission__isset __isset;
-
- void __set_jobSubmissionDataID(const std::string& val) {
- jobSubmissionDataID = val;
- }
-
- void __set_resourceJobManager(const ResourceJobManager::type val) {
- resourceJobManager = val;
- }
-
- void __set_sshPort(const int32_t val) {
- sshPort = val;
- __isset.sshPort = true;
- }
-
- bool operator == (const SSHJobSubmission & rhs) const
- {
- if (!(jobSubmissionDataID == rhs.jobSubmissionDataID))
- return false;
- if (!(resourceJobManager == rhs.resourceJobManager))
- return false;
- if (__isset.sshPort != rhs.__isset.sshPort)
- return false;
- else if (__isset.sshPort && !(sshPort == rhs.sshPort))
- return false;
- return true;
- }
- bool operator != (const SSHJobSubmission &rhs) const {
- return !(*this == rhs);
- }
-
- bool operator < (const SSHJobSubmission & ) const;
-
- uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
- uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
-
-};
-
-void swap(SSHJobSubmission &a, SSHJobSubmission &b);
-
-typedef struct _GlobusJobSubmission__isset {
- _GlobusJobSubmission__isset() : globusGateKeeperEndPoint(false) {}
- bool globusGateKeeperEndPoint;
-} _GlobusJobSubmission__isset;
-
-class GlobusJobSubmission {
- public:
-
- static const char* ascii_fingerprint; // = "DF4253F78D7B543C16FA461660D38A03";
- static const uint8_t binary_fingerprint[16]; // = {0xDF,0x42,0x53,0xF7,0x8D,0x7B,0x54,0x3C,0x16,0xFA,0x46,0x16,0x60,0xD3,0x8A,0x03};
-
- GlobusJobSubmission() : jobSubmissionDataID("DO_NOT_SET_AT_CLIENTS"), securityProtocol((SecurityProtocol::type)0), resourceJobManager((ResourceJobManager::type)0) {
- }
-
- virtual ~GlobusJobSubmission() throw() {}
-
- std::string jobSubmissionDataID;
- SecurityProtocol::type securityProtocol;
- ResourceJobManager::type resourceJobManager;
- std::vector<std::string> globusGateKeeperEndPoint;
-
- _GlobusJobSubmission__isset __isset;
-
- void __set_jobSubmissionDataID(const std::string& val) {
- jobSubmissionDataID = val;
- }
-
- void __set_securityProtocol(const SecurityProtocol::type val) {
- securityProtocol = val;
- }
-
- void __set_resourceJobManager(const ResourceJobManager::type val) {
- resourceJobManager = val;
- }
-
- void __set_globusGateKeeperEndPoint(const std::vector<std::string> & val) {
- globusGateKeeperEndPoint = val;
- __isset.globusGateKeeperEndPoint = true;
- }
-
- bool operator == (const GlobusJobSubmission & rhs) const
- {
- if (!(jobSubmissionDataID == rhs.jobSubmissionDataID))
- return false;
- if (!(securityProtocol == rhs.securityProtocol))
- return false;
- if (!(resourceJobManager == rhs.resourceJobManager))
- return false;
- if (__isset.globusGateKeeperEndPoint != rhs.__isset.globusGateKeeperEndPoint)
- return false;
- else if (__isset.globusGateKeeperEndPoint && !(globusGateKeeperEndPoint == rhs.globusGateKeeperEndPoint))
- return false;
- return true;
- }
- bool operator != (const GlobusJobSubmission &rhs) const {
- return !(*this == rhs);
- }
-
- bool operator < (const GlobusJobSubmission & ) const;
-
- uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
- uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
-
-};
-
-void swap(GlobusJobSubmission &a, GlobusJobSubmission &b);
-
-typedef struct _GSISSHJobSubmission__isset {
- _GSISSHJobSubmission__isset() : sshPort(true), exports(false), preJobCommands(false), postJobCommands(false), installedPath(false), monitorMode(false) {}
- bool sshPort;
- bool exports;
- bool preJobCommands;
- bool postJobCommands;
- bool installedPath;
- bool monitorMode;
-} _GSISSHJobSubmission__isset;
-
-class GSISSHJobSubmission {
- public:
-
- static const char* ascii_fingerprint; // = "6969A7F145C4403B2F9081A498E933FD";
- static const uint8_t binary_fingerprint[16]; // = {0x69,0x69,0xA7,0xF1,0x45,0xC4,0x40,0x3B,0x2F,0x90,0x81,0xA4,0x98,0xE9,0x33,0xFD};
-
- GSISSHJobSubmission() : jobSubmissionDataID("DO_NOT_SET_AT_CLIENTS"), resourceJobManager((ResourceJobManager::type)0), sshPort(22), installedPath(), monitorMode() {
- }
-
- virtual ~GSISSHJobSubmission() throw() {}
-
- std::string jobSubmissionDataID;
- ResourceJobManager::type resourceJobManager;
- int32_t sshPort;
- std::set<std::string> exports;
- std::vector<std::string> preJobCommands;
- std::vector<std::string> postJobCommands;
- std::string installedPath;
- std::string monitorMode;
-
- _GSISSHJobSubmission__isset __isset;
-
- void __set_jobSubmissionDataID(const std::string& val) {
- jobSubmissionDataID = val;
- }
-
- void __set_resourceJobManager(const ResourceJobManager::type val) {
- resourceJobManager = val;
- }
-
- void __set_sshPort(const int32_t val) {
- sshPort = val;
- __isset.sshPort = true;
- }
-
- void __set_exports(const std::set<std::string> & val) {
- exports = val;
- __isset.exports = true;
- }
-
- void __set_preJobCommands(const std::vector<std::string> & val) {
- preJobCommands = val;
- __isset.preJobCommands = true;
- }
-
- void __set_postJobCommands(const std::vector<std::string> & val) {
- postJobCommands = val;
- __isset.postJobCommands = true;
- }
-
- void __set_installedPath(const std::string& val) {
- installedPath = val;
- __isset.installedPath = true;
- }
-
- void __set_monitorMode(const std::string& val) {
- monitorMode = val;
- __isset.monitorMode = true;
- }
-
- bool operator == (const GSISSHJobSubmission & rhs) const
- {
- if (!(jobSubmissionDataID == rhs.jobSubmissionDataID))
- return false;
- if (!(resourceJobManager == rhs.resourceJobManager))
- return false;
- if (__isset.sshPort != rhs.__isset.sshPort)
- return false;
- else if (__isset.sshPort && !(sshPort == rhs.sshPort))
- return false;
- if (__isset.exports != rhs.__isset.exports)
- return false;
- else if (__isset.exports && !(exports == rhs.exports))
- return false;
- if (__isset.preJobCommands != rhs.__isset.preJobCommands)
- return false;
- else if (__isset.preJobCommands && !(preJobCommands == rhs.preJobCommands))
- return false;
- if (__isset.postJobCommands != rhs.__isset.postJobCommands)
- return false;
- else if (__isset.postJobCommands && !(postJobCommands == rhs.postJobCommands))
- return false;
- if (__isset.installedPath != rhs.__isset.installedPath)
- return false;
- else if (__isset.installedPath && !(installedPath == rhs.installedPath))
- return false;
- if (__isset.monitorMode != rhs.__isset.monitorMode)
- return false;
- else if (__isset.monitorMode && !(monitorMode == rhs.monitorMode))
- return false;
- return true;
- }
- bool operator != (const GSISSHJobSubmission &rhs) const {
- return !(*this == rhs);
- }
-
- bool operator < (const GSISSHJobSubmission & ) const;
-
- uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
- uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
-
-};
-
-void swap(GSISSHJobSubmission &a, GSISSHJobSubmission &b);
-
-typedef struct _ComputeResourceDescription__isset {
- _ComputeResourceDescription__isset() : hostAliases(false), ipAddresses(false), resourceDescription(false), preferredJobSubmissionProtocol(false) {}
- bool hostAliases;
- bool ipAddresses;
- bool resourceDescription;
- bool preferredJobSubmissionProtocol;
-} _ComputeResourceDescription__isset;
-
-class ComputeResourceDescription {
- public:
-
- static const char* ascii_fingerprint; // = "A31E9EF4FF0C9ADE9027FD5C59A96555";
- static const uint8_t binary_fingerprint[16]; // = {0xA3,0x1E,0x9E,0xF4,0xFF,0x0C,0x9A,0xDE,0x90,0x27,0xFD,0x5C,0x59,0xA9,0x65,0x55};
-
- ComputeResourceDescription() : isEmpty(false), resourceId("DO_NOT_SET_AT_CLIENTS"), hostName(), resourceDescription(), preferredJobSubmissionProtocol() {
- }
-
- virtual ~ComputeResourceDescription() throw() {}
-
- bool isEmpty;
- std::string resourceId;
- std::string hostName;
- std::set<std::string> hostAliases;
- std::set<std::string> ipAddresses;
- std::string resourceDescription;
- std::string preferredJobSubmissionProtocol;
- std::map<std::string, JobSubmissionProtocol::type> jobSubmissionProtocols;
- std::map<std::string, DataMovementProtocol::type> dataMovementProtocols;
-
- _ComputeResourceDescription__isset __isset;
-
- void __set_isEmpty(const bool val) {
- isEmpty = val;
- }
-
- void __set_resourceId(const std::string& val) {
- resourceId = val;
- }
-
- void __set_hostName(const std::string& val) {
- hostName = val;
- }
-
- void __set_hostAliases(const std::set<std::string> & val) {
- hostAliases = val;
- __isset.hostAliases = true;
- }
-
- void __set_ipAddresses(const std::set<std::string> & val) {
- ipAddresses = val;
- __isset.ipAddresses = true;
- }
-
- void __set_resourceDescription(const std::string& val) {
- resourceDescription = val;
- __isset.resourceDescription = true;
- }
-
- void __set_preferredJobSubmissionProtocol(const std::string& val) {
- preferredJobSubmissionProtocol = val;
- __isset.preferredJobSubmissionProtocol = true;
- }
-
- void __set_jobSubmissionProtocols(const std::map<std::string, JobSubmissionProtocol::type> & val) {
- jobSubmissionProtocols = val;
- }
-
- void __set_dataMovementProtocols(const std::map<std::string, DataMovementProtocol::type> & val) {
- dataMovementProtocols = val;
- }
-
- bool operator == (const ComputeResourceDescription & rhs) const
- {
- if (!(isEmpty == rhs.isEmpty))
- return false;
- if (!(resourceId == rhs.resourceId))
- return false;
- if (!(hostName == rhs.hostName))
- return false;
- if (__isset.hostAliases != rhs.__isset.hostAliases)
- return false;
- else if (__isset.hostAliases && !(hostAliases == rhs.hostAliases))
- return false;
- if (__isset.ipAddresses != rhs.__isset.ipAddresses)
- return false;
- else if (__isset.ipAddresses && !(ipAddresses == rhs.ipAddresses))
- return false;
- if (__isset.resourceDescription != rhs.__isset.resourceDescription)
- return false;
- else if (__isset.resourceDescription && !(resourceDescription == rhs.resourceDescription))
- return false;
- if (__isset.preferredJobSubmissionProtocol != rhs.__isset.preferredJobSubmissionProtocol)
- return false;
- else if (__isset.preferredJobSubmissionProtocol && !(preferredJobSubmissionProtocol == rhs.preferredJobSubmissionProtocol))
- return false;
- if (!(jobSubmissionProtocols == rhs.jobSubmissionProtocols))
- return false;
- if (!(dataMovementProtocols == rhs.dataMovementProtocols))
- return false;
- return true;
- }
- bool operator != (const ComputeResourceDescription &rhs) const {
- return !(*this == rhs);
- }
-
- bool operator < (const ComputeResourceDescription & ) const;
-
- uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
- uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
-
-};
-
-void swap(ComputeResourceDescription &a, ComputeResourceDescription &b);
-
-
-
-#endif
http://git-wip-us.apache.org/repos/asf/airavata/blob/0a002531/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_constants.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_constants.cpp
new file mode 100644
index 0000000..c201757
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_constants.cpp
@@ -0,0 +1,19 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.1)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#include "computeResourceModel_constants.h"
+
+
+
+const computeResourceModelConstants g_computeResourceModel_constants;
+
+computeResourceModelConstants::computeResourceModelConstants() {
+ DEFAULT_ID = "DO_NOT_SET_AT_CLIENTS";
+
+}
+
+
+
http://git-wip-us.apache.org/repos/asf/airavata/blob/0a002531/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_constants.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_constants.h
new file mode 100644
index 0000000..93f2029
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/computeResourceModel_constants.h
@@ -0,0 +1,25 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.1)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#ifndef computeResourceModel_CONSTANTS_H
+#define computeResourceModel_CONSTANTS_H
+
+#include "computeResourceModel_types.h"
+
+
+
+class computeResourceModelConstants {
+ public:
+ computeResourceModelConstants();
+
+ std::string DEFAULT_ID;
+};
+
+extern const computeResourceModelConstants g_computeResourceModel_constants;
+
+
+
+#endif