You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2015/09/30 17:14:25 UTC
[1/2] airavata-php-gateway git commit: updating libraries
Repository: airavata-php-gateway
Updated Branches:
refs/heads/master 72d9c66eb -> 0909397d5
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/0909397d/app/libraries/Airavata/Model/AppCatalog/ComputeResource/Types.php
----------------------------------------------------------------------
diff --git a/app/libraries/Airavata/Model/AppCatalog/ComputeResource/Types.php b/app/libraries/Airavata/Model/AppCatalog/ComputeResource/Types.php
index 6891a0d..e5bff2c 100644
--- a/app/libraries/Airavata/Model/AppCatalog/ComputeResource/Types.php
+++ b/app/libraries/Airavata/Model/AppCatalog/ComputeResource/Types.php
@@ -1332,6 +1332,13 @@ class LOCALDataMovement {
*
* sshPort:
* If a non-default port needs to used, specify it.
+ *
+ * batchQueueEmailSenders:
+ * If a resource always sends the monitoring from a specific address, specify the
+ * full email address. If a resource sends emails from multiple addresses (
+ * example: based on the submitted login node) then use the wildchar * to indicate
+ * the same. Example: *@*.example.com or *@example.com
+ *
*/
class SSHJobSubmission {
static $_TSPEC;
@@ -1360,6 +1367,10 @@ class SSHJobSubmission {
* @var int
*/
public $monitorMode = null;
+ /**
+ * @var string[]
+ */
+ public $batchQueueEmailSenders = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -1389,6 +1400,14 @@ class SSHJobSubmission {
'var' => 'monitorMode',
'type' => TType::I32,
),
+ 7 => array(
+ 'var' => 'batchQueueEmailSenders',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
);
}
if (is_array($vals)) {
@@ -1410,6 +1429,9 @@ class SSHJobSubmission {
if (isset($vals['monitorMode'])) {
$this->monitorMode = $vals['monitorMode'];
}
+ if (isset($vals['batchQueueEmailSenders'])) {
+ $this->batchQueueEmailSenders = $vals['batchQueueEmailSenders'];
+ }
}
}
@@ -1475,6 +1497,23 @@ class SSHJobSubmission {
$xfer += $input->skip($ftype);
}
break;
+ case 7:
+ if ($ftype == TType::LST) {
+ $this->batchQueueEmailSenders = array();
+ $_size16 = 0;
+ $_etype19 = 0;
+ $xfer += $input->readListBegin($_etype19, $_size16);
+ for ($_i20 = 0; $_i20 < $_size16; ++$_i20)
+ {
+ $elem21 = null;
+ $xfer += $input->readString($elem21);
+ $this->batchQueueEmailSenders []= $elem21;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -1521,6 +1560,23 @@ class SSHJobSubmission {
$xfer += $output->writeI32($this->monitorMode);
$xfer += $output->writeFieldEnd();
}
+ if ($this->batchQueueEmailSenders !== null) {
+ if (!is_array($this->batchQueueEmailSenders)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('batchQueueEmailSenders', TType::LST, 7);
+ {
+ $output->writeListBegin(TType::STRING, count($this->batchQueueEmailSenders));
+ {
+ foreach ($this->batchQueueEmailSenders as $iter22)
+ {
+ $xfer += $output->writeString($iter22);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -1614,14 +1670,14 @@ class GlobusJobSubmission {
case 3:
if ($ftype == TType::LST) {
$this->globusGateKeeperEndPoint = array();
- $_size16 = 0;
- $_etype19 = 0;
- $xfer += $input->readListBegin($_etype19, $_size16);
- for ($_i20 = 0; $_i20 < $_size16; ++$_i20)
+ $_size23 = 0;
+ $_etype26 = 0;
+ $xfer += $input->readListBegin($_etype26, $_size23);
+ for ($_i27 = 0; $_i27 < $_size23; ++$_i27)
{
- $elem21 = null;
- $xfer += $input->readString($elem21);
- $this->globusGateKeeperEndPoint []= $elem21;
+ $elem28 = null;
+ $xfer += $input->readString($elem28);
+ $this->globusGateKeeperEndPoint []= $elem28;
}
$xfer += $input->readListEnd();
} else {
@@ -1659,9 +1715,9 @@ class GlobusJobSubmission {
{
$output->writeListBegin(TType::STRING, count($this->globusGateKeeperEndPoint));
{
- foreach ($this->globusGateKeeperEndPoint as $iter22)
+ foreach ($this->globusGateKeeperEndPoint as $iter29)
{
- $xfer += $output->writeString($iter22);
+ $xfer += $output->writeString($iter29);
}
}
$output->writeListEnd();
@@ -2491,14 +2547,14 @@ class ComputeResourceDescription {
case 3:
if ($ftype == TType::LST) {
$this->hostAliases = array();
- $_size23 = 0;
- $_etype26 = 0;
- $xfer += $input->readListBegin($_etype26, $_size23);
- for ($_i27 = 0; $_i27 < $_size23; ++$_i27)
+ $_size30 = 0;
+ $_etype33 = 0;
+ $xfer += $input->readListBegin($_etype33, $_size30);
+ for ($_i34 = 0; $_i34 < $_size30; ++$_i34)
{
- $elem28 = null;
- $xfer += $input->readString($elem28);
- $this->hostAliases []= $elem28;
+ $elem35 = null;
+ $xfer += $input->readString($elem35);
+ $this->hostAliases []= $elem35;
}
$xfer += $input->readListEnd();
} else {
@@ -2508,14 +2564,14 @@ class ComputeResourceDescription {
case 4:
if ($ftype == TType::LST) {
$this->ipAddresses = array();
- $_size29 = 0;
- $_etype32 = 0;
- $xfer += $input->readListBegin($_etype32, $_size29);
- for ($_i33 = 0; $_i33 < $_size29; ++$_i33)
+ $_size36 = 0;
+ $_etype39 = 0;
+ $xfer += $input->readListBegin($_etype39, $_size36);
+ for ($_i40 = 0; $_i40 < $_size36; ++$_i40)
{
- $elem34 = null;
- $xfer += $input->readString($elem34);
- $this->ipAddresses []= $elem34;
+ $elem41 = null;
+ $xfer += $input->readString($elem41);
+ $this->ipAddresses []= $elem41;
}
$xfer += $input->readListEnd();
} else {
@@ -2539,15 +2595,15 @@ class ComputeResourceDescription {
case 7:
if ($ftype == TType::LST) {
$this->batchQueues = array();
- $_size35 = 0;
- $_etype38 = 0;
- $xfer += $input->readListBegin($_etype38, $_size35);
- for ($_i39 = 0; $_i39 < $_size35; ++$_i39)
+ $_size42 = 0;
+ $_etype45 = 0;
+ $xfer += $input->readListBegin($_etype45, $_size42);
+ for ($_i46 = 0; $_i46 < $_size42; ++$_i46)
{
- $elem40 = null;
- $elem40 = new \Airavata\Model\AppCatalog\ComputeResource\BatchQueue();
- $xfer += $elem40->read($input);
- $this->batchQueues []= $elem40;
+ $elem47 = null;
+ $elem47 = new \Airavata\Model\AppCatalog\ComputeResource\BatchQueue();
+ $xfer += $elem47->read($input);
+ $this->batchQueues []= $elem47;
}
$xfer += $input->readListEnd();
} else {
@@ -2557,17 +2613,17 @@ class ComputeResourceDescription {
case 8:
if ($ftype == TType::MAP) {
$this->fileSystems = array();
- $_size41 = 0;
- $_ktype42 = 0;
- $_vtype43 = 0;
- $xfer += $input->readMapBegin($_ktype42, $_vtype43, $_size41);
- for ($_i45 = 0; $_i45 < $_size41; ++$_i45)
+ $_size48 = 0;
+ $_ktype49 = 0;
+ $_vtype50 = 0;
+ $xfer += $input->readMapBegin($_ktype49, $_vtype50, $_size48);
+ for ($_i52 = 0; $_i52 < $_size48; ++$_i52)
{
- $key46 = 0;
- $val47 = '';
- $xfer += $input->readI32($key46);
- $xfer += $input->readString($val47);
- $this->fileSystems[$key46] = $val47;
+ $key53 = 0;
+ $val54 = '';
+ $xfer += $input->readI32($key53);
+ $xfer += $input->readString($val54);
+ $this->fileSystems[$key53] = $val54;
}
$xfer += $input->readMapEnd();
} else {
@@ -2577,15 +2633,15 @@ class ComputeResourceDescription {
case 9:
if ($ftype == TType::LST) {
$this->jobSubmissionInterfaces = array();
- $_size48 = 0;
- $_etype51 = 0;
- $xfer += $input->readListBegin($_etype51, $_size48);
- for ($_i52 = 0; $_i52 < $_size48; ++$_i52)
+ $_size55 = 0;
+ $_etype58 = 0;
+ $xfer += $input->readListBegin($_etype58, $_size55);
+ for ($_i59 = 0; $_i59 < $_size55; ++$_i59)
{
- $elem53 = null;
- $elem53 = new \Airavata\Model\AppCatalog\ComputeResource\JobSubmissionInterface();
- $xfer += $elem53->read($input);
- $this->jobSubmissionInterfaces []= $elem53;
+ $elem60 = null;
+ $elem60 = new \Airavata\Model\AppCatalog\ComputeResource\JobSubmissionInterface();
+ $xfer += $elem60->read($input);
+ $this->jobSubmissionInterfaces []= $elem60;
}
$xfer += $input->readListEnd();
} else {
@@ -2595,15 +2651,15 @@ class ComputeResourceDescription {
case 10:
if ($ftype == TType::LST) {
$this->dataMovementInterfaces = array();
- $_size54 = 0;
- $_etype57 = 0;
- $xfer += $input->readListBegin($_etype57, $_size54);
- for ($_i58 = 0; $_i58 < $_size54; ++$_i58)
+ $_size61 = 0;
+ $_etype64 = 0;
+ $xfer += $input->readListBegin($_etype64, $_size61);
+ for ($_i65 = 0; $_i65 < $_size61; ++$_i65)
{
- $elem59 = null;
- $elem59 = new \Airavata\Model\AppCatalog\ComputeResource\DataMovementInterface();
- $xfer += $elem59->read($input);
- $this->dataMovementInterfaces []= $elem59;
+ $elem66 = null;
+ $elem66 = new \Airavata\Model\AppCatalog\ComputeResource\DataMovementInterface();
+ $xfer += $elem66->read($input);
+ $this->dataMovementInterfaces []= $elem66;
}
$xfer += $input->readListEnd();
} else {
@@ -2648,9 +2704,9 @@ class ComputeResourceDescription {
{
$output->writeListBegin(TType::STRING, count($this->hostAliases));
{
- foreach ($this->hostAliases as $iter60)
+ foreach ($this->hostAliases as $iter67)
{
- $xfer += $output->writeString($iter60);
+ $xfer += $output->writeString($iter67);
}
}
$output->writeListEnd();
@@ -2665,9 +2721,9 @@ class ComputeResourceDescription {
{
$output->writeListBegin(TType::STRING, count($this->ipAddresses));
{
- foreach ($this->ipAddresses as $iter61)
+ foreach ($this->ipAddresses as $iter68)
{
- $xfer += $output->writeString($iter61);
+ $xfer += $output->writeString($iter68);
}
}
$output->writeListEnd();
@@ -2692,9 +2748,9 @@ class ComputeResourceDescription {
{
$output->writeListBegin(TType::STRUCT, count($this->batchQueues));
{
- foreach ($this->batchQueues as $iter62)
+ foreach ($this->batchQueues as $iter69)
{
- $xfer += $iter62->write($output);
+ $xfer += $iter69->write($output);
}
}
$output->writeListEnd();
@@ -2709,10 +2765,10 @@ class ComputeResourceDescription {
{
$output->writeMapBegin(TType::I32, TType::STRING, count($this->fileSystems));
{
- foreach ($this->fileSystems as $kiter63 => $viter64)
+ foreach ($this->fileSystems as $kiter70 => $viter71)
{
- $xfer += $output->writeI32($kiter63);
- $xfer += $output->writeString($viter64);
+ $xfer += $output->writeI32($kiter70);
+ $xfer += $output->writeString($viter71);
}
}
$output->writeMapEnd();
@@ -2727,9 +2783,9 @@ class ComputeResourceDescription {
{
$output->writeListBegin(TType::STRUCT, count($this->jobSubmissionInterfaces));
{
- foreach ($this->jobSubmissionInterfaces as $iter65)
+ foreach ($this->jobSubmissionInterfaces as $iter72)
{
- $xfer += $iter65->write($output);
+ $xfer += $iter72->write($output);
}
}
$output->writeListEnd();
@@ -2744,9 +2800,9 @@ class ComputeResourceDescription {
{
$output->writeListBegin(TType::STRUCT, count($this->dataMovementInterfaces));
{
- foreach ($this->dataMovementInterfaces as $iter66)
+ foreach ($this->dataMovementInterfaces as $iter73)
{
- $xfer += $iter66->write($output);
+ $xfer += $iter73->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/0909397d/app/libraries/Airavata/Model/AppCatalog/GatewayProfile/Types.php
----------------------------------------------------------------------
diff --git a/app/libraries/Airavata/Model/AppCatalog/GatewayProfile/Types.php b/app/libraries/Airavata/Model/AppCatalog/GatewayProfile/Types.php
index a94dd88..f63f2f0 100644
--- a/app/libraries/Airavata/Model/AppCatalog/GatewayProfile/Types.php
+++ b/app/libraries/Airavata/Model/AppCatalog/GatewayProfile/Types.php
@@ -46,6 +46,10 @@ use Thrift\Exception\TApplicationException;
* allocation is approved, an allocation number is assigned. Before passing this number with job submittions, the
* account to be used has to be added to the allocation.
*
+ * resourceSpecificCredentialStoreToken:
+ * Resource specific credential store token. If this token is specified, then it is superceeded by the gateway's
+ * default credential store.
+ *
*/
class ComputeResourcePreference {
static $_TSPEC;
@@ -82,6 +86,10 @@ class ComputeResourcePreference {
* @var string
*/
public $allocationProjectNumber = null;
+ /**
+ * @var string
+ */
+ public $resourceSpecificCredentialStoreToken = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -118,6 +126,10 @@ class ComputeResourcePreference {
'var' => 'allocationProjectNumber',
'type' => TType::STRING,
),
+ 9 => array(
+ 'var' => 'resourceSpecificCredentialStoreToken',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
@@ -145,6 +157,9 @@ class ComputeResourcePreference {
if (isset($vals['allocationProjectNumber'])) {
$this->allocationProjectNumber = $vals['allocationProjectNumber'];
}
+ if (isset($vals['resourceSpecificCredentialStoreToken'])) {
+ $this->resourceSpecificCredentialStoreToken = $vals['resourceSpecificCredentialStoreToken'];
+ }
}
}
@@ -223,6 +238,13 @@ class ComputeResourcePreference {
$xfer += $input->skip($ftype);
}
break;
+ case 9:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->resourceSpecificCredentialStoreToken);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -276,6 +298,155 @@ class ComputeResourcePreference {
$xfer += $output->writeString($this->allocationProjectNumber);
$xfer += $output->writeFieldEnd();
}
+ if ($this->resourceSpecificCredentialStoreToken !== null) {
+ $xfer += $output->writeFieldBegin('resourceSpecificCredentialStoreToken', TType::STRING, 9);
+ $xfer += $output->writeString($this->resourceSpecificCredentialStoreToken);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class DataStoragePreference {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $dataMovememtResourceId = null;
+ /**
+ * @var string
+ */
+ public $loginUserName = null;
+ /**
+ * @var string
+ */
+ public $fileSystemRootLocation = null;
+ /**
+ * @var string
+ */
+ public $resourceSpecificCredentialStoreToken = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dataMovememtResourceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'loginUserName',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'fileSystemRootLocation',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'resourceSpecificCredentialStoreToken',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dataMovememtResourceId'])) {
+ $this->dataMovememtResourceId = $vals['dataMovememtResourceId'];
+ }
+ if (isset($vals['loginUserName'])) {
+ $this->loginUserName = $vals['loginUserName'];
+ }
+ if (isset($vals['fileSystemRootLocation'])) {
+ $this->fileSystemRootLocation = $vals['fileSystemRootLocation'];
+ }
+ if (isset($vals['resourceSpecificCredentialStoreToken'])) {
+ $this->resourceSpecificCredentialStoreToken = $vals['resourceSpecificCredentialStoreToken'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'DataStoragePreference';
+ }
+
+ 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->dataMovememtResourceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->loginUserName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->fileSystemRootLocation);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->resourceSpecificCredentialStoreToken);
+ } 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('DataStoragePreference');
+ if ($this->dataMovememtResourceId !== null) {
+ $xfer += $output->writeFieldBegin('dataMovememtResourceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->dataMovememtResourceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->loginUserName !== null) {
+ $xfer += $output->writeFieldBegin('loginUserName', TType::STRING, 2);
+ $xfer += $output->writeString($this->loginUserName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->fileSystemRootLocation !== null) {
+ $xfer += $output->writeFieldBegin('fileSystemRootLocation', TType::STRING, 3);
+ $xfer += $output->writeString($this->fileSystemRootLocation);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->resourceSpecificCredentialStoreToken !== null) {
+ $xfer += $output->writeFieldBegin('resourceSpecificCredentialStoreToken', TType::STRING, 4);
+ $xfer += $output->writeString($this->resourceSpecificCredentialStoreToken);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -287,12 +458,14 @@ class ComputeResourcePreference {
* Gateway Resource Profile
*
* gatewayID:
- * Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration.
+ * Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration.
+ *
+ * credentialStoreToken:
+ * Gateway's defualt credential store token.
*
* computeResourcePreferences:
* List of resource preferences for each of the registered compute resources.
*
- *
*/
class GatewayResourceProfile {
static $_TSPEC;
@@ -302,9 +475,17 @@ class GatewayResourceProfile {
*/
public $gatewayID = null;
/**
+ * @var string
+ */
+ public $credentialStoreToken = null;
+ /**
* @var \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference[]
*/
public $computeResourcePreferences = null;
+ /**
+ * @var \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference[]
+ */
+ public $dataStoragePreferences = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -314,6 +495,10 @@ class GatewayResourceProfile {
'type' => TType::STRING,
),
2 => array(
+ 'var' => 'credentialStoreToken',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
'var' => 'computeResourcePreferences',
'type' => TType::LST,
'etype' => TType::STRUCT,
@@ -322,15 +507,30 @@ class GatewayResourceProfile {
'class' => '\Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference',
),
),
+ 4 => array(
+ 'var' => 'dataStoragePreferences',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference',
+ ),
+ ),
);
}
if (is_array($vals)) {
if (isset($vals['gatewayID'])) {
$this->gatewayID = $vals['gatewayID'];
}
+ if (isset($vals['credentialStoreToken'])) {
+ $this->credentialStoreToken = $vals['credentialStoreToken'];
+ }
if (isset($vals['computeResourcePreferences'])) {
$this->computeResourcePreferences = $vals['computeResourcePreferences'];
}
+ if (isset($vals['dataStoragePreferences'])) {
+ $this->dataStoragePreferences = $vals['dataStoragePreferences'];
+ }
}
}
@@ -361,6 +561,13 @@ class GatewayResourceProfile {
}
break;
case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->credentialStoreToken);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
if ($ftype == TType::LST) {
$this->computeResourcePreferences = array();
$_size0 = 0;
@@ -378,6 +585,24 @@ class GatewayResourceProfile {
$xfer += $input->skip($ftype);
}
break;
+ case 4:
+ if ($ftype == TType::LST) {
+ $this->dataStoragePreferences = array();
+ $_size6 = 0;
+ $_etype9 = 0;
+ $xfer += $input->readListBegin($_etype9, $_size6);
+ for ($_i10 = 0; $_i10 < $_size6; ++$_i10)
+ {
+ $elem11 = null;
+ $elem11 = new \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference();
+ $xfer += $elem11->read($input);
+ $this->dataStoragePreferences []= $elem11;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -396,17 +621,39 @@ class GatewayResourceProfile {
$xfer += $output->writeString($this->gatewayID);
$xfer += $output->writeFieldEnd();
}
+ if ($this->credentialStoreToken !== null) {
+ $xfer += $output->writeFieldBegin('credentialStoreToken', TType::STRING, 2);
+ $xfer += $output->writeString($this->credentialStoreToken);
+ $xfer += $output->writeFieldEnd();
+ }
if ($this->computeResourcePreferences !== null) {
if (!is_array($this->computeResourcePreferences)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
}
- $xfer += $output->writeFieldBegin('computeResourcePreferences', TType::LST, 2);
+ $xfer += $output->writeFieldBegin('computeResourcePreferences', TType::LST, 3);
{
$output->writeListBegin(TType::STRUCT, count($this->computeResourcePreferences));
{
- foreach ($this->computeResourcePreferences as $iter6)
+ foreach ($this->computeResourcePreferences as $iter12)
+ {
+ $xfer += $iter12->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataStoragePreferences !== null) {
+ if (!is_array($this->dataStoragePreferences)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('dataStoragePreferences', TType::LST, 4);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->dataStoragePreferences));
+ {
+ foreach ($this->dataStoragePreferences as $iter13)
{
- $xfer += $iter6->write($output);
+ $xfer += $iter13->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/0909397d/app/libraries/Airavata/Model/Status/Types.php
----------------------------------------------------------------------
diff --git a/app/libraries/Airavata/Model/Status/Types.php b/app/libraries/Airavata/Model/Status/Types.php
index 603e75b..2a21e14 100644
--- a/app/libraries/Airavata/Model/Status/Types.php
+++ b/app/libraries/Airavata/Model/Status/Types.php
@@ -58,31 +58,33 @@ final class TaskState {
final class ProcessState {
const CREATED = 0;
const VALIDATED = 1;
- const PRE_PROCESSING = 2;
- const CONFIGURING_WORKSPACE = 3;
- const INPUT_DATA_STAGING = 4;
- const EXECUTING = 5;
- const MONITORING = 6;
- const OUTPUT_DATA_STAGING = 7;
- const POST_PROCESSING = 8;
- const COMPLETED = 9;
- const FAILED = 10;
- const CANCELLING = 11;
- const CANCELED = 12;
+ const STARTED = 2;
+ const PRE_PROCESSING = 3;
+ const CONFIGURING_WORKSPACE = 4;
+ const INPUT_DATA_STAGING = 5;
+ const EXECUTING = 6;
+ const MONITORING = 7;
+ const OUTPUT_DATA_STAGING = 8;
+ const POST_PROCESSING = 9;
+ const COMPLETED = 10;
+ const FAILED = 11;
+ const CANCELLING = 12;
+ const CANCELED = 13;
static public $__names = array(
0 => 'CREATED',
1 => 'VALIDATED',
- 2 => 'PRE_PROCESSING',
- 3 => 'CONFIGURING_WORKSPACE',
- 4 => 'INPUT_DATA_STAGING',
- 5 => 'EXECUTING',
- 6 => 'MONITORING',
- 7 => 'OUTPUT_DATA_STAGING',
- 8 => 'POST_PROCESSING',
- 9 => 'COMPLETED',
- 10 => 'FAILED',
- 11 => 'CANCELLING',
- 12 => 'CANCELED',
+ 2 => 'STARTED',
+ 3 => 'PRE_PROCESSING',
+ 4 => 'CONFIGURING_WORKSPACE',
+ 5 => 'INPUT_DATA_STAGING',
+ 6 => 'EXECUTING',
+ 7 => 'MONITORING',
+ 8 => 'OUTPUT_DATA_STAGING',
+ 9 => 'POST_PROCESSING',
+ 10 => 'COMPLETED',
+ 11 => 'FAILED',
+ 12 => 'CANCELLING',
+ 13 => 'CANCELED',
);
}
[2/2] airavata-php-gateway git commit: updating libraries
Posted by ch...@apache.org.
updating libraries
Project: http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/commit/0909397d
Tree: http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/tree/0909397d
Diff: http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/diff/0909397d
Branch: refs/heads/master
Commit: 0909397d5e92a99e61691a1365043607eabea872
Parents: 72d9c66
Author: Chathuri Wimalasena <ch...@apache.org>
Authored: Wed Sep 30 11:14:21 2015 -0400
Committer: Chathuri Wimalasena <ch...@apache.org>
Committed: Wed Sep 30 11:14:21 2015 -0400
----------------------------------------------------------------------
app/libraries/Airavata/API/Airavata.php | 2190 +++++++++++++++++-
.../Model/AppCatalog/ComputeResource/Types.php | 196 +-
.../Model/AppCatalog/GatewayProfile/Types.php | 257 +-
app/libraries/Airavata/Model/Status/Types.php | 46 +-
4 files changed, 2480 insertions(+), 209 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/0909397d/app/libraries/Airavata/API/Airavata.php
----------------------------------------------------------------------
diff --git a/app/libraries/Airavata/API/Airavata.php b/app/libraries/Airavata/API/Airavata.php
index 6455693..f274185 100644
--- a/app/libraries/Airavata/API/Airavata.php
+++ b/app/libraries/Airavata/API/Airavata.php
@@ -1609,6 +1609,13 @@ interface AiravataIf {
* sshPort:
* If a non-default port needs to used, specify it.
*
+ * batchQueueEmailSenders:
+ * If a resource always sends the monitoring from a specific address, specify the
+ * full email address. If a resource sends emails from multiple addresses (
+ * example: based on the submitted login node) then use the wildchar * to indicate
+ * the same. Example: *@*.example.com or *@example.com
+ *
+ *
* @throws \Airavata\API\Error\InvalidRequestException
* @throws \Airavata\API\Error\AiravataClientException
* @throws \Airavata\API\Error\AiravataSystemException
@@ -2257,13 +2264,15 @@ interface AiravataIf {
* @return \Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile Gateway Resource Profile
*
* gatewayID:
- * Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration.
+ * Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration.
+ *
+ * credentialStoreToken:
+ * Gateway's defualt credential store token.
*
* computeResourcePreferences:
* List of resource preferences for each of the registered compute resources.
*
*
- *
* @throws \Airavata\API\Error\InvalidRequestException
* @throws \Airavata\API\Error\AiravataClientException
* @throws \Airavata\API\Error\AiravataSystemException
@@ -2341,6 +2350,18 @@ interface AiravataIf {
*/
public function addGatewayComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $computeResourceId, \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference $computeResourcePreference);
/**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $gatewayID
+ * @param string $dataMoveId
+ * @param \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference $dataStoragePreference
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function addGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId, \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference $dataStoragePreference);
+ /**
* Fetch a Compute Resource Preference of a registered gateway profile.
*
* @param gatewayID
@@ -2384,6 +2405,10 @@ interface AiravataIf {
* allocation is approved, an allocation number is assigned. Before passing this number with job submittions, the
* account to be used has to be added to the allocation.
*
+ * resourceSpecificCredentialStoreToken:
+ * Resource specific credential store token. If this token is specified, then it is superceeded by the gateway's
+ * default credential store.
+ *
*
* @throws \Airavata\API\Error\InvalidRequestException
* @throws \Airavata\API\Error\AiravataClientException
@@ -2392,6 +2417,17 @@ interface AiravataIf {
*/
public function getGatewayComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $computeResourceId);
/**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $gatewayID
+ * @param string $dataMoveId
+ * @return \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function getGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId);
+ /**
* Fetch all Compute Resource Preferences of a registered gateway profile.
*
* @param gatewayID
@@ -2411,6 +2447,16 @@ interface AiravataIf {
*/
public function getAllGatewayComputeResourcePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID);
/**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $gatewayID
+ * @return \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference[]
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function getAllGatewayDataStoragePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID);
+ /**
* Fetch all gateway profiles registered
*
*
@@ -2450,6 +2496,18 @@ interface AiravataIf {
*/
public function updateGatewayComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $computeResourceId, \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference $computeResourcePreference);
/**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $gatewayID
+ * @param string $dataMoveId
+ * @param \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference $dataStoragePreference
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function updateGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId, \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference $dataStoragePreference);
+ /**
* Delete the Compute Resource Preference of a registered gateway profile.
*
* @param gatewayID
@@ -2474,6 +2532,17 @@ interface AiravataIf {
public function deleteGatewayComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $computeResourceId);
/**
* @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $gatewayID
+ * @param string $dataMoveId
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function deleteGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId);
+ /**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
* @param string $gatewayId
* @return string[]
* @throws \Airavata\API\Error\InvalidRequestException
@@ -9430,6 +9499,72 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("addGatewayComputeResourcePreference failed: unknown result");
}
+ public function addGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId, \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference $dataStoragePreference)
+ {
+ $this->send_addGatewayDataStoragePreference($authzToken, $gatewayID, $dataMoveId, $dataStoragePreference);
+ return $this->recv_addGatewayDataStoragePreference();
+ }
+
+ public function send_addGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId, \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference $dataStoragePreference)
+ {
+ $args = new \Airavata\API\Airavata_addGatewayDataStoragePreference_args();
+ $args->authzToken = $authzToken;
+ $args->gatewayID = $gatewayID;
+ $args->dataMoveId = $dataMoveId;
+ $args->dataStoragePreference = $dataStoragePreference;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'addGatewayDataStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('addGatewayDataStoragePreference', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_addGatewayDataStoragePreference()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_addGatewayDataStoragePreference_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Airavata\API\Airavata_addGatewayDataStoragePreference_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("addGatewayDataStoragePreference failed: unknown result");
+ }
+
public function getGatewayComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $computeResourceId)
{
$this->send_getGatewayComputeResourcePreference($authzToken, $gatewayID, $computeResourceId);
@@ -9495,6 +9630,71 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("getGatewayComputeResourcePreference failed: unknown result");
}
+ public function getGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId)
+ {
+ $this->send_getGatewayDataStoragePreference($authzToken, $gatewayID, $dataMoveId);
+ return $this->recv_getGatewayDataStoragePreference();
+ }
+
+ public function send_getGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId)
+ {
+ $args = new \Airavata\API\Airavata_getGatewayDataStoragePreference_args();
+ $args->authzToken = $authzToken;
+ $args->gatewayID = $gatewayID;
+ $args->dataMoveId = $dataMoveId;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getGatewayDataStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getGatewayDataStoragePreference', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getGatewayDataStoragePreference()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getGatewayDataStoragePreference_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Airavata\API\Airavata_getGatewayDataStoragePreference_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("getGatewayDataStoragePreference failed: unknown result");
+ }
+
public function getAllGatewayComputeResourcePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID)
{
$this->send_getAllGatewayComputeResourcePreferences($authzToken, $gatewayID);
@@ -9559,6 +9759,70 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("getAllGatewayComputeResourcePreferences failed: unknown result");
}
+ public function getAllGatewayDataStoragePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID)
+ {
+ $this->send_getAllGatewayDataStoragePreferences($authzToken, $gatewayID);
+ return $this->recv_getAllGatewayDataStoragePreferences();
+ }
+
+ public function send_getAllGatewayDataStoragePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID)
+ {
+ $args = new \Airavata\API\Airavata_getAllGatewayDataStoragePreferences_args();
+ $args->authzToken = $authzToken;
+ $args->gatewayID = $gatewayID;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getAllGatewayDataStoragePreferences', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getAllGatewayDataStoragePreferences', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getAllGatewayDataStoragePreferences()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllGatewayDataStoragePreferences_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Airavata\API\Airavata_getAllGatewayDataStoragePreferences_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("getAllGatewayDataStoragePreferences failed: unknown result");
+ }
+
public function getAllGatewayComputeResources(\Airavata\Model\Security\AuthzToken $authzToken)
{
$this->send_getAllGatewayComputeResources($authzToken);
@@ -9688,6 +9952,72 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("updateGatewayComputeResourcePreference failed: unknown result");
}
+ public function updateGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId, \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference $dataStoragePreference)
+ {
+ $this->send_updateGatewayDataStoragePreference($authzToken, $gatewayID, $dataMoveId, $dataStoragePreference);
+ return $this->recv_updateGatewayDataStoragePreference();
+ }
+
+ public function send_updateGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId, \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference $dataStoragePreference)
+ {
+ $args = new \Airavata\API\Airavata_updateGatewayDataStoragePreference_args();
+ $args->authzToken = $authzToken;
+ $args->gatewayID = $gatewayID;
+ $args->dataMoveId = $dataMoveId;
+ $args->dataStoragePreference = $dataStoragePreference;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'updateGatewayDataStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('updateGatewayDataStoragePreference', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_updateGatewayDataStoragePreference()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateGatewayDataStoragePreference_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Airavata\API\Airavata_updateGatewayDataStoragePreference_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("updateGatewayDataStoragePreference failed: unknown result");
+ }
+
public function deleteGatewayComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $computeResourceId)
{
$this->send_deleteGatewayComputeResourcePreference($authzToken, $gatewayID, $computeResourceId);
@@ -9753,6 +10083,71 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("deleteGatewayComputeResourcePreference failed: unknown result");
}
+ public function deleteGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId)
+ {
+ $this->send_deleteGatewayDataStoragePreference($authzToken, $gatewayID, $dataMoveId);
+ return $this->recv_deleteGatewayDataStoragePreference();
+ }
+
+ public function send_deleteGatewayDataStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $dataMoveId)
+ {
+ $args = new \Airavata\API\Airavata_deleteGatewayDataStoragePreference_args();
+ $args->authzToken = $authzToken;
+ $args->gatewayID = $gatewayID;
+ $args->dataMoveId = $dataMoveId;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'deleteGatewayDataStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('deleteGatewayDataStoragePreference', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_deleteGatewayDataStoragePreference()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteGatewayDataStoragePreference_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Airavata\API\Airavata_deleteGatewayDataStoragePreference_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("deleteGatewayDataStoragePreference failed: unknown result");
+ }
+
public function getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId)
{
$this->send_getAllWorkflows($authzToken, $gatewayId);
@@ -42965,7 +43360,7 @@ class Airavata_addGatewayComputeResourcePreference_result {
}
-class Airavata_getGatewayComputeResourcePreference_args {
+class Airavata_addGatewayDataStoragePreference_args {
static $_TSPEC;
/**
@@ -42979,7 +43374,11 @@ class Airavata_getGatewayComputeResourcePreference_args {
/**
* @var string
*/
- public $computeResourceId = null;
+ public $dataMoveId = null;
+ /**
+ * @var \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference
+ */
+ public $dataStoragePreference = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -42994,9 +43393,14 @@ class Airavata_getGatewayComputeResourcePreference_args {
'type' => TType::STRING,
),
3 => array(
- 'var' => 'computeResourceId',
+ 'var' => 'dataMoveId',
'type' => TType::STRING,
),
+ 4 => array(
+ 'var' => 'dataStoragePreference',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference',
+ ),
);
}
if (is_array($vals)) {
@@ -43006,14 +43410,17 @@ class Airavata_getGatewayComputeResourcePreference_args {
if (isset($vals['gatewayID'])) {
$this->gatewayID = $vals['gatewayID'];
}
- if (isset($vals['computeResourceId'])) {
- $this->computeResourceId = $vals['computeResourceId'];
+ if (isset($vals['dataMoveId'])) {
+ $this->dataMoveId = $vals['dataMoveId'];
+ }
+ if (isset($vals['dataStoragePreference'])) {
+ $this->dataStoragePreference = $vals['dataStoragePreference'];
}
}
}
public function getName() {
- return 'Airavata_getGatewayComputeResourcePreference_args';
+ return 'Airavata_addGatewayDataStoragePreference_args';
}
public function read($input)
@@ -43048,7 +43455,15 @@ class Airavata_getGatewayComputeResourcePreference_args {
break;
case 3:
if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->computeResourceId);
+ $xfer += $input->readString($this->dataMoveId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRUCT) {
+ $this->dataStoragePreference = new \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference();
+ $xfer += $this->dataStoragePreference->read($input);
} else {
$xfer += $input->skip($ftype);
}
@@ -43065,7 +43480,7 @@ class Airavata_getGatewayComputeResourcePreference_args {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_getGatewayComputeResourcePreference_args');
+ $xfer += $output->writeStructBegin('Airavata_addGatewayDataStoragePreference_args');
if ($this->authzToken !== null) {
if (!is_object($this->authzToken)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
@@ -43079,9 +43494,17 @@ class Airavata_getGatewayComputeResourcePreference_args {
$xfer += $output->writeString($this->gatewayID);
$xfer += $output->writeFieldEnd();
}
- if ($this->computeResourceId !== null) {
- $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 3);
- $xfer += $output->writeString($this->computeResourceId);
+ if ($this->dataMoveId !== null) {
+ $xfer += $output->writeFieldBegin('dataMoveId', TType::STRING, 3);
+ $xfer += $output->writeString($this->dataMoveId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataStoragePreference !== null) {
+ if (!is_object($this->dataStoragePreference)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('dataStoragePreference', TType::STRUCT, 4);
+ $xfer += $this->dataStoragePreference->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
@@ -43091,11 +43514,11 @@ class Airavata_getGatewayComputeResourcePreference_args {
}
-class Airavata_getGatewayComputeResourcePreference_result {
+class Airavata_addGatewayDataStoragePreference_result {
static $_TSPEC;
/**
- * @var \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference
+ * @var bool
*/
public $success = null;
/**
@@ -43120,8 +43543,7 @@ class Airavata_getGatewayComputeResourcePreference_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference',
+ 'type' => TType::BOOL,
),
1 => array(
'var' => 'ire',
@@ -43165,7 +43587,7 @@ class Airavata_getGatewayComputeResourcePreference_result {
}
public function getName() {
- return 'Airavata_getGatewayComputeResourcePreference_result';
+ return 'Airavata_addGatewayDataStoragePreference_result';
}
public function read($input)
@@ -43184,9 +43606,8 @@ class Airavata_getGatewayComputeResourcePreference_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::STRUCT) {
- $this->success = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
- $xfer += $this->success->read($input);
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -43235,13 +43656,10 @@ class Airavata_getGatewayComputeResourcePreference_result {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_getGatewayComputeResourcePreference_result');
+ $xfer += $output->writeStructBegin('Airavata_addGatewayDataStoragePreference_result');
if ($this->success !== null) {
- if (!is_object($this->success)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
- $xfer += $this->success->write($output);
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($this->success);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -43271,7 +43689,7 @@ class Airavata_getGatewayComputeResourcePreference_result {
}
-class Airavata_getAllGatewayComputeResourcePreferences_args {
+class Airavata_getGatewayComputeResourcePreference_args {
static $_TSPEC;
/**
@@ -43282,6 +43700,10 @@ class Airavata_getAllGatewayComputeResourcePreferences_args {
* @var string
*/
public $gatewayID = null;
+ /**
+ * @var string
+ */
+ public $computeResourceId = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -43295,6 +43717,10 @@ class Airavata_getAllGatewayComputeResourcePreferences_args {
'var' => 'gatewayID',
'type' => TType::STRING,
),
+ 3 => array(
+ 'var' => 'computeResourceId',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
@@ -43304,11 +43730,14 @@ class Airavata_getAllGatewayComputeResourcePreferences_args {
if (isset($vals['gatewayID'])) {
$this->gatewayID = $vals['gatewayID'];
}
+ if (isset($vals['computeResourceId'])) {
+ $this->computeResourceId = $vals['computeResourceId'];
+ }
}
}
public function getName() {
- return 'Airavata_getAllGatewayComputeResourcePreferences_args';
+ return 'Airavata_getGatewayComputeResourcePreference_args';
}
public function read($input)
@@ -43341,6 +43770,13 @@ class Airavata_getAllGatewayComputeResourcePreferences_args {
$xfer += $input->skip($ftype);
}
break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->computeResourceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -43353,7 +43789,7 @@ class Airavata_getAllGatewayComputeResourcePreferences_args {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_getAllGatewayComputeResourcePreferences_args');
+ $xfer += $output->writeStructBegin('Airavata_getGatewayComputeResourcePreference_args');
if ($this->authzToken !== null) {
if (!is_object($this->authzToken)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
@@ -43367,6 +43803,11 @@ class Airavata_getAllGatewayComputeResourcePreferences_args {
$xfer += $output->writeString($this->gatewayID);
$xfer += $output->writeFieldEnd();
}
+ if ($this->computeResourceId !== null) {
+ $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 3);
+ $xfer += $output->writeString($this->computeResourceId);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -43374,11 +43815,11 @@ class Airavata_getAllGatewayComputeResourcePreferences_args {
}
-class Airavata_getAllGatewayComputeResourcePreferences_result {
+class Airavata_getGatewayComputeResourcePreference_result {
static $_TSPEC;
/**
- * @var \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference[]
+ * @var \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference
*/
public $success = null;
/**
@@ -43403,12 +43844,8 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::LST,
- 'etype' => TType::STRUCT,
- 'elem' => array(
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference',
- ),
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference',
),
1 => array(
'var' => 'ire',
@@ -43452,7 +43889,7 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
}
public function getName() {
- return 'Airavata_getAllGatewayComputeResourcePreferences_result';
+ return 'Airavata_getGatewayComputeResourcePreference_result';
}
public function read($input)
@@ -43471,19 +43908,9 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::LST) {
- $this->success = array();
- $_size219 = 0;
- $_etype222 = 0;
- $xfer += $input->readListBegin($_etype222, $_size219);
- for ($_i223 = 0; $_i223 < $_size219; ++$_i223)
- {
- $elem224 = null;
- $elem224 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
- $xfer += $elem224->read($input);
- $this->success []= $elem224;
- }
- $xfer += $input->readListEnd();
+ if ($ftype == TType::STRUCT) {
+ $this->success = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
+ $xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
}
@@ -43532,22 +43959,13 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_getAllGatewayComputeResourcePreferences_result');
+ $xfer += $output->writeStructBegin('Airavata_getGatewayComputeResourcePreference_result');
if ($this->success !== null) {
- if (!is_array($this->success)) {
+ if (!is_object($this->success)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
}
- $xfer += $output->writeFieldBegin('success', TType::LST, 0);
- {
- $output->writeListBegin(TType::STRUCT, count($this->success));
- {
- foreach ($this->success as $iter225)
- {
- $xfer += $iter225->write($output);
- }
- }
- $output->writeListEnd();
- }
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $this->success->write($output);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -43577,13 +43995,21 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
}
-class Airavata_getAllGatewayComputeResources_args {
+class Airavata_getGatewayDataStoragePreference_args {
static $_TSPEC;
/**
* @var \Airavata\Model\Security\AuthzToken
*/
public $authzToken = null;
+ /**
+ * @var string
+ */
+ public $gatewayID = null;
+ /**
+ * @var string
+ */
+ public $dataMoveId = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -43593,17 +44019,31 @@ class Airavata_getAllGatewayComputeResources_args {
'type' => TType::STRUCT,
'class' => '\Airavata\Model\Security\AuthzToken',
),
+ 2 => array(
+ 'var' => 'gatewayID',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'dataMoveId',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
if (isset($vals['authzToken'])) {
$this->authzToken = $vals['authzToken'];
}
+ if (isset($vals['gatewayID'])) {
+ $this->gatewayID = $vals['gatewayID'];
+ }
+ if (isset($vals['dataMoveId'])) {
+ $this->dataMoveId = $vals['dataMoveId'];
+ }
}
}
public function getName() {
- return 'Airavata_getAllGatewayComputeResources_args';
+ return 'Airavata_getGatewayDataStoragePreference_args';
}
public function read($input)
@@ -43629,6 +44069,20 @@ class Airavata_getAllGatewayComputeResources_args {
$xfer += $input->skip($ftype);
}
break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->gatewayID);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dataMoveId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -43641,7 +44095,7 @@ class Airavata_getAllGatewayComputeResources_args {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_getAllGatewayComputeResources_args');
+ $xfer += $output->writeStructBegin('Airavata_getGatewayDataStoragePreference_args');
if ($this->authzToken !== null) {
if (!is_object($this->authzToken)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
@@ -43650,6 +44104,16 @@ class Airavata_getAllGatewayComputeResources_args {
$xfer += $this->authzToken->write($output);
$xfer += $output->writeFieldEnd();
}
+ if ($this->gatewayID !== null) {
+ $xfer += $output->writeFieldBegin('gatewayID', TType::STRING, 2);
+ $xfer += $output->writeString($this->gatewayID);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataMoveId !== null) {
+ $xfer += $output->writeFieldBegin('dataMoveId', TType::STRING, 3);
+ $xfer += $output->writeString($this->dataMoveId);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -43657,11 +44121,11 @@ class Airavata_getAllGatewayComputeResources_args {
}
-class Airavata_getAllGatewayComputeResources_result {
+class Airavata_getGatewayDataStoragePreference_result {
static $_TSPEC;
/**
- * @var \Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile[]
+ * @var \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference
*/
public $success = null;
/**
@@ -43686,12 +44150,8 @@ class Airavata_getAllGatewayComputeResources_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::LST,
- 'etype' => TType::STRUCT,
- 'elem' => array(
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile',
- ),
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference',
),
1 => array(
'var' => 'ire',
@@ -43735,7 +44195,7 @@ class Airavata_getAllGatewayComputeResources_result {
}
public function getName() {
- return 'Airavata_getAllGatewayComputeResources_result';
+ return 'Airavata_getGatewayDataStoragePreference_result';
}
public function read($input)
@@ -43754,19 +44214,9 @@ class Airavata_getAllGatewayComputeResources_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::LST) {
- $this->success = array();
- $_size226 = 0;
- $_etype229 = 0;
- $xfer += $input->readListBegin($_etype229, $_size226);
- for ($_i230 = 0; $_i230 < $_size226; ++$_i230)
- {
- $elem231 = null;
- $elem231 = new \Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile();
- $xfer += $elem231->read($input);
- $this->success []= $elem231;
- }
- $xfer += $input->readListEnd();
+ if ($ftype == TType::STRUCT) {
+ $this->success = new \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference();
+ $xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
}
@@ -43815,22 +44265,908 @@ class Airavata_getAllGatewayComputeResources_result {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_getAllGatewayComputeResources_result');
+ $xfer += $output->writeStructBegin('Airavata_getGatewayDataStoragePreference_result');
if ($this->success !== null) {
- if (!is_array($this->success)) {
+ if (!is_object($this->success)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
}
- $xfer += $output->writeFieldBegin('success', TType::LST, 0);
- {
- $output->writeListBegin(TType::STRUCT, count($this->success));
- {
- foreach ($this->success as $iter232)
- {
- $xfer += $iter232->write($output);
- }
- }
- $output->writeListEnd();
- }
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $this->success->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ire !== null) {
+ $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1);
+ $xfer += $this->ire->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ace !== null) {
+ $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2);
+ $xfer += $this->ace->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ase !== null) {
+ $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3);
+ $xfer += $this->ase->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 4);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_getAllGatewayComputeResourcePreferences_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+ /**
+ * @var string
+ */
+ public $gatewayID = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ 2 => array(
+ 'var' => 'gatewayID',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ if (isset($vals['gatewayID'])) {
+ $this->gatewayID = $vals['gatewayID'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getAllGatewayComputeResourcePreferences_args';
+ }
+
+ 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::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->gatewayID);
+ } 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('Airavata_getAllGatewayComputeResourcePreferences_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->gatewayID !== null) {
+ $xfer += $output->writeFieldBegin('gatewayID', TType::STRING, 2);
+ $xfer += $output->writeString($this->gatewayID);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_getAllGatewayComputeResourcePreferences_result {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference[]
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\API\Error\InvalidRequestException
+ */
+ public $ire = null;
+ /**
+ * @var \Airavata\API\Error\AiravataClientException
+ */
+ public $ace = null;
+ /**
+ * @var \Airavata\API\Error\AiravataSystemException
+ */
+ public $ase = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference',
+ ),
+ ),
+ 1 => array(
+ 'var' => 'ire',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\InvalidRequestException',
+ ),
+ 2 => array(
+ 'var' => 'ace',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataClientException',
+ ),
+ 3 => array(
+ 'var' => 'ase',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataSystemException',
+ ),
+ 4 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['ire'])) {
+ $this->ire = $vals['ire'];
+ }
+ if (isset($vals['ace'])) {
+ $this->ace = $vals['ace'];
+ }
+ if (isset($vals['ase'])) {
+ $this->ase = $vals['ase'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getAllGatewayComputeResourcePreferences_result';
+ }
+
+ 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 0:
+ if ($ftype == TType::LST) {
+ $this->success = array();
+ $_size219 = 0;
+ $_etype222 = 0;
+ $xfer += $input->readListBegin($_etype222, $_size219);
+ for ($_i223 = 0; $_i223 < $_size219; ++$_i223)
+ {
+ $elem224 = null;
+ $elem224 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
+ $xfer += $elem224->read($input);
+ $this->success []= $elem224;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->ire = new \Airavata\API\Error\InvalidRequestException();
+ $xfer += $this->ire->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ace = new \Airavata\API\Error\AiravataClientException();
+ $xfer += $this->ace->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->ase = new \Airavata\API\Error\AiravataSystemException();
+ $xfer += $this->ase->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_getAllGatewayComputeResourcePreferences_result');
+ if ($this->success !== null) {
+ if (!is_array($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::LST, 0);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->success));
+ {
+ foreach ($this->success as $iter225)
+ {
+ $xfer += $iter225->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ire !== null) {
+ $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1);
+ $xfer += $this->ire->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ace !== null) {
+ $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2);
+ $xfer += $this->ace->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ase !== null) {
+ $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3);
+ $xfer += $this->ase->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 4);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_getAllGatewayDataStoragePreferences_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+ /**
+ * @var string
+ */
+ public $gatewayID = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ 2 => array(
+ 'var' => 'gatewayID',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ if (isset($vals['gatewayID'])) {
+ $this->gatewayID = $vals['gatewayID'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getAllGatewayDataStoragePreferences_args';
+ }
+
+ 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::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->gatewayID);
+ } 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('Airavata_getAllGatewayDataStoragePreferences_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->gatewayID !== null) {
+ $xfer += $output->writeFieldBegin('gatewayID', TType::STRING, 2);
+ $xfer += $output->writeString($this->gatewayID);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_getAllGatewayDataStoragePreferences_result {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference[]
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\API\Error\InvalidRequestException
+ */
+ public $ire = null;
+ /**
+ * @var \Airavata\API\Error\AiravataClientException
+ */
+ public $ace = null;
+ /**
+ * @var \Airavata\API\Error\AiravataSystemException
+ */
+ public $ase = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference',
+ ),
+ ),
+ 1 => array(
+ 'var' => 'ire',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\InvalidRequestException',
+ ),
+ 2 => array(
+ 'var' => 'ace',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataClientException',
+ ),
+ 3 => array(
+ 'var' => 'ase',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataSystemException',
+ ),
+ 4 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['ire'])) {
+ $this->ire = $vals['ire'];
+ }
+ if (isset($vals['ace'])) {
+ $this->ace = $vals['ace'];
+ }
+ if (isset($vals['ase'])) {
+ $this->ase = $vals['ase'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getAllGatewayDataStoragePreferences_result';
+ }
+
+ 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 0:
+ if ($ftype == TType::LST) {
+ $this->success = array();
+ $_size226 = 0;
+ $_etype229 = 0;
+ $xfer += $input->readListBegin($_etype229, $_size226);
+ for ($_i230 = 0; $_i230 < $_size226; ++$_i230)
+ {
+ $elem231 = null;
+ $elem231 = new \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference();
+ $xfer += $elem231->read($input);
+ $this->success []= $elem231;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->ire = new \Airavata\API\Error\InvalidRequestException();
+ $xfer += $this->ire->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ace = new \Airavata\API\Error\AiravataClientException();
+ $xfer += $this->ace->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->ase = new \Airavata\API\Error\AiravataSystemException();
+ $xfer += $this->ase->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_getAllGatewayDataStoragePreferences_result');
+ if ($this->success !== null) {
+ if (!is_array($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::LST, 0);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->success));
+ {
+ foreach ($this->success as $iter232)
+ {
+ $xfer += $iter232->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ire !== null) {
+ $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1);
+ $xfer += $this->ire->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ace !== null) {
+ $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2);
+ $xfer += $this->ace->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ase !== null) {
+ $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3);
+ $xfer += $this->ase->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 4);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_getAllGatewayComputeResources_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getAllGatewayComputeResources_args';
+ }
+
+ 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::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_getAllGatewayComputeResources_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_getAllGatewayComputeResources_result {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile[]
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\API\Error\InvalidRequestException
+ */
+ public $ire = null;
+ /**
+ * @var \Airavata\API\Error\AiravataClientException
+ */
+ public $ace = null;
+ /**
+ * @var \Airavata\API\Error\AiravataSystemException
+ */
+ public $ase = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile',
+ ),
+ ),
+ 1 => array(
+ 'var' => 'ire',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\InvalidRequestException',
+ ),
+ 2 => array(
+ 'var' => 'ace',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataClientException',
+ ),
+ 3 => array(
+ 'var' => 'ase',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataSystemException',
+ ),
+ 4 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['ire'])) {
+ $this->ire = $vals['ire'];
+ }
+ if (isset($vals['ace'])) {
+ $this->ace = $vals['ace'];
+ }
+ if (isset($vals['ase'])) {
+ $this->ase = $vals['ase'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getAllGatewayComputeResources_result';
+ }
+
+ 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 0:
+ if ($ftype == TType::LST) {
+ $this->success = array();
+ $_size233 = 0;
+ $_etype236 = 0;
+ $xfer += $input->readListBegin($_etype236, $_size233);
+ for ($_i237 = 0; $_i237 < $_size233; ++$_i237)
+ {
+ $elem238 = null;
+ $elem238 = new \Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile();
+ $xfer += $elem238->read($input);
+ $this->success []= $elem238;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->ire = new \Airavata\API\Error\InvalidRequestException();
+ $xfer += $this->ire->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ace = new \Airavata\API\Error\AiravataClientException();
+ $xfer += $this->ace->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->ase = new \Airavata\API\Error\AiravataSystemException();
+ $xfer += $this->ase->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_getAllGatewayComputeResources_result');
+ if ($this->success !== null) {
+ if (!is_array($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::LST, 0);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->success));
+ {
+ foreach ($this->success as $iter239)
+ {
+ $xfer += $iter239->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -44189,6 +45525,335 @@ class Airavata_updateGatewayComputeResourcePreference_result {
}
+class Airavata_updateGatewayDataStoragePreference_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+ /**
+ * @var string
+ */
+ public $gatewayID = null;
+ /**
+ * @var string
+ */
+ public $dataMoveId = null;
+ /**
+ * @var \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference
+ */
+ public $dataStoragePreference = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ 2 => array(
+ 'var' => 'gatewayID',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'dataMoveId',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'dataStoragePreference',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ if (isset($vals['gatewayID'])) {
+ $this->gatewayID = $vals['gatewayID'];
+ }
+ if (isset($vals['dataMoveId'])) {
+ $this->dataMoveId = $vals['dataMoveId'];
+ }
+ if (isset($vals['dataStoragePreference'])) {
+ $this->dataStoragePreference = $vals['dataStoragePreference'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_updateGatewayDataStoragePreference_args';
+ }
+
+ 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::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->gatewayID);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dataMoveId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRUCT) {
+ $this->dataStoragePreference = new \Airavata\Model\AppCatalog\GatewayProfile\DataStoragePreference();
+ $xfer += $this->dataStoragePreference->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_updateGatewayDataStoragePreference_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->gatewayID !== null) {
+ $xfer += $output->writeFieldBegin('gatewayID', TType::STRING, 2);
+ $xfer += $output->writeString($this->gatewayID);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataMoveId !== null) {
+ $xfer += $output->writeFieldBegin('dataMoveId', TType::STRING, 3);
+ $xfer += $output->writeString($this->dataMoveId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataStoragePreference !== null) {
+ if (!is_object($this->dataStoragePreference)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('dataStoragePreference', TType::STRUCT, 4);
+ $xfer += $this->dataStoragePreference->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_updateGatewayDataStoragePreference_result {
+ static $_TSPEC;
+
+ /**
+ * @var bool
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\API\Error\InvalidRequestException
+ */
+ public $ire = null;
+ /**
+ * @var \Airavata\API\Error\AiravataClientException
+ */
+ public $ace = null;
+ /**
+ * @var \Airavata\API\Error\AiravataSystemException
+ */
+ public $ase = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::BOOL,
+ ),
+ 1 => array(
+ 'var' => 'ire',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\InvalidRequestException',
+ ),
+ 2 => array(
+ 'var' => 'ace',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataClientException',
+ ),
+ 3 => array(
+ 'var' => 'ase',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataSystemException',
+ ),
+ 4 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['ire'])) {
+ $this->ire = $vals['ire'];
+ }
+ if (isset($vals['ace'])) {
+ $this->ace = $vals['ace'];
+ }
+ if (isset($vals['ase'])) {
+ $this->ase = $vals['ase'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_updateGatewayDataStoragePreference_result';
+ }
+
+ 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 0:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->success);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->ire = new \Airavata\API\Error\InvalidRequestException();
+ $xfer += $this->ire->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ace = new \Airavata\API\Error\AiravataClientException();
+ $xfer += $this->ace->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->ase = new \Airavata\API\Error\AiravataSystemException();
+ $xfer += $this->ase->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_updateGatewayDataStoragePreference_result');
+ if ($this->success !== null) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ire !== null) {
+ $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1);
+ $xfer += $this->ire->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ace !== null) {
+ $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2);
+ $xfer += $this->ace->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ase !== null) {
+ $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3);
+ $xfer += $this->ase->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 4);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class Airavata_deleteGatewayComputeResourcePreference_args {
static $_TSPEC;
@@ -44490,6 +46155,307 @@ class Airavata_deleteGatewayComputeResourcePreference_result {
}
+class Airavata_deleteGatewayDataStoragePreference_args {
+ static $_TSPEC;
+
+ /**
+ * @var \Airavata\Model\Security\AuthzToken
+ */
+ public $authzToken = null;
+ /**
+ * @var string
+ */
+ public $gatewayID = null;
+ /**
+ * @var string
+ */
+ public $dataMoveId = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'authzToken',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Security\AuthzToken',
+ ),
+ 2 => array(
+ 'var' => 'gatewayID',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'dataMoveId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['authzToken'])) {
+ $this->authzToken = $vals['authzToken'];
+ }
+ if (isset($vals['gatewayID'])) {
+ $this->gatewayID = $vals['gatewayID'];
+ }
+ if (isset($vals['dataMoveId'])) {
+ $this->dataMoveId = $vals['dataMoveId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_deleteGatewayDataStoragePreference_args';
+ }
+
+ 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::STRUCT) {
+ $this->authzToken = new \Airavata\Model\Security\AuthzToken();
+ $xfer += $this->authzToken->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->gatewayID);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dataMoveId);
+ } 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('Airavata_deleteGatewayDataStoragePreference_args');
+ if ($this->authzToken !== null) {
+ if (!is_object($this->authzToken)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
+ $xfer += $this->authzToken->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->gatewayID !== null) {
+ $xfer += $output->writeFieldBegin('gatewayID', TType::STRING, 2);
+ $xfer += $output->writeString($this->gatewayID);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataMoveId !== null) {
+ $xfer += $output->writeFieldBegin('dataMoveId', TType::STRING, 3);
+ $xfer += $output->writeString($this->dataMoveId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_deleteGatewayDataStoragePreference_result {
+ static $_TSPEC;
+
+ /**
+ * @var bool
+ */
+ public $success = null;
+ /**
+ * @var \Airavata\API\Error\InvalidRequestException
+ */
+ public $ire = null;
+ /**
+ * @var \Airavata\API\Error\AiravataClientException
+ */
+ public $ace = null;
+ /**
+ * @var \Airavata\API\Error\AiravataSystemException
+ */
+ public $ase = null;
+ /**
+ * @var \Airavata\API\Error\AuthorizationException
+ */
+ public $ae = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::BOOL,
+ ),
+ 1 => array(
+ 'var' => 'ire',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\InvalidRequestException',
+ ),
+ 2 => array(
+ 'var' => 'ace',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataClientException',
+ ),
+ 3 => array(
+ 'var' => 'ase',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataSystemException',
+ ),
+ 4 => array(
+ 'var' => 'ae',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AuthorizationException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['ire'])) {
+ $this->ire = $vals['ire'];
+ }
+ if (isset($vals['ace'])) {
+ $this->ace = $vals['ace'];
+ }
+ if (isset($vals['ase'])) {
+ $this->ase = $vals['ase'];
+ }
+ if (isset($vals['ae'])) {
+ $this->ae = $vals['ae'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_deleteGatewayDataStoragePreference_result';
+ }
+
+ 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 0:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->success);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->ire = new \Airavata\API\Error\InvalidRequestException();
+ $xfer += $this->ire->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ace = new \Airavata\API\Error\AiravataClientException();
+ $xfer += $this->ace->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->ase = new \Airavata\API\Error\AiravataSystemException();
+ $xfer += $this->ase->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRUCT) {
+ $this->ae = new \Airavata\API\Error\AuthorizationException();
+ $xfer += $this->ae->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_deleteGatewayDataStoragePreference_result');
+ if ($this->success !== null) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ire !== null) {
+ $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1);
+ $xfer += $this->ire->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ace !== null) {
+ $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2);
+ $xfer += $this->ace->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ase !== null) {
+ $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3);
+ $xfer += $this->ase->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ae !== null) {
+ $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 4);
+ $xfer += $this->ae->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class Airavata_getAllWorkflows_args {
static $_TSPEC;
@@ -44691,14 +46657,14 @@ class Airavata_getAllWorkflows_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size233 = 0;
- $_etype236 = 0;
- $xfer += $input->readListBegin($_etype236, $_size233);
- for ($_i237 = 0; $_i237 < $_size233; ++$_i237)
+ $_size240 = 0;
+ $_etype243 = 0;
+ $xfer += $input->readListBegin($_etype243, $_size240);
+ for ($_i244 = 0; $_i244 < $_size240; ++$_i244)
{
- $elem238 = null;
- $xfer += $input->readString($elem238);
- $this->success []= $elem238;
+ $elem245 = null;
+ $xfer += $input->readString($elem245);
+ $this->success []= $elem245;
}
$xfer += $input->readListEnd();
} else {
@@ -44758,9 +46724,9 @@ class Airavata_getAllWorkflows_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter239)
+ foreach ($this->success as $iter246)
{
- $xfer += $output->writeString($iter239);
+ $xfer += $output->writeString($iter246);
}
}
$output->writeListEnd();