You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2015/03/03 18:34:56 UTC
[1/5] airavata git commit: Stubs for credential store api methods -
AIRAVATA-1616
Repository: airavata
Updated Branches:
refs/heads/master f9f63a025 -> 33b403fc7
http://git-wip-us.apache.org/repos/asf/airavata/blob/33b403fc/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/AppCatalog/GatewayProfile/Types.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/AppCatalog/GatewayProfile/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/AppCatalog/GatewayProfile/Types.php
index bdb70e4..e0e6227 100644
--- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/AppCatalog/GatewayProfile/Types.php
+++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/AppCatalog/GatewayProfile/Types.php
@@ -22,6 +22,7 @@ class ComputeResourcePreference {
public $computeResourceId = null;
public $overridebyAiravata = true;
+ public $loginUserName = null;
public $preferredJobSubmissionProtocol = null;
public $preferredDataMovementProtocol = null;
public $preferredBatchQueue = null;
@@ -40,22 +41,26 @@ class ComputeResourcePreference {
'type' => TType::BOOL,
),
3 => array(
+ 'var' => 'loginUserName',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
'var' => 'preferredJobSubmissionProtocol',
'type' => TType::I32,
),
- 4 => array(
+ 5 => array(
'var' => 'preferredDataMovementProtocol',
'type' => TType::I32,
),
- 5 => array(
+ 6 => array(
'var' => 'preferredBatchQueue',
'type' => TType::STRING,
),
- 6 => array(
+ 7 => array(
'var' => 'scratchLocation',
'type' => TType::STRING,
),
- 7 => array(
+ 8 => array(
'var' => 'allocationProjectNumber',
'type' => TType::STRING,
),
@@ -68,6 +73,9 @@ class ComputeResourcePreference {
if (isset($vals['overridebyAiravata'])) {
$this->overridebyAiravata = $vals['overridebyAiravata'];
}
+ if (isset($vals['loginUserName'])) {
+ $this->loginUserName = $vals['loginUserName'];
+ }
if (isset($vals['preferredJobSubmissionProtocol'])) {
$this->preferredJobSubmissionProtocol = $vals['preferredJobSubmissionProtocol'];
}
@@ -120,34 +128,41 @@ class ComputeResourcePreference {
}
break;
case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->loginUserName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
if ($ftype == TType::I32) {
$xfer += $input->readI32($this->preferredJobSubmissionProtocol);
} else {
$xfer += $input->skip($ftype);
}
break;
- case 4:
+ case 5:
if ($ftype == TType::I32) {
$xfer += $input->readI32($this->preferredDataMovementProtocol);
} else {
$xfer += $input->skip($ftype);
}
break;
- case 5:
+ case 6:
if ($ftype == TType::STRING) {
$xfer += $input->readString($this->preferredBatchQueue);
} else {
$xfer += $input->skip($ftype);
}
break;
- case 6:
+ case 7:
if ($ftype == TType::STRING) {
$xfer += $input->readString($this->scratchLocation);
} else {
$xfer += $input->skip($ftype);
}
break;
- case 7:
+ case 8:
if ($ftype == TType::STRING) {
$xfer += $input->readString($this->allocationProjectNumber);
} else {
@@ -177,28 +192,33 @@ class ComputeResourcePreference {
$xfer += $output->writeBool($this->overridebyAiravata);
$xfer += $output->writeFieldEnd();
}
+ if ($this->loginUserName !== null) {
+ $xfer += $output->writeFieldBegin('loginUserName', TType::STRING, 3);
+ $xfer += $output->writeString($this->loginUserName);
+ $xfer += $output->writeFieldEnd();
+ }
if ($this->preferredJobSubmissionProtocol !== null) {
- $xfer += $output->writeFieldBegin('preferredJobSubmissionProtocol', TType::I32, 3);
+ $xfer += $output->writeFieldBegin('preferredJobSubmissionProtocol', TType::I32, 4);
$xfer += $output->writeI32($this->preferredJobSubmissionProtocol);
$xfer += $output->writeFieldEnd();
}
if ($this->preferredDataMovementProtocol !== null) {
- $xfer += $output->writeFieldBegin('preferredDataMovementProtocol', TType::I32, 4);
+ $xfer += $output->writeFieldBegin('preferredDataMovementProtocol', TType::I32, 5);
$xfer += $output->writeI32($this->preferredDataMovementProtocol);
$xfer += $output->writeFieldEnd();
}
if ($this->preferredBatchQueue !== null) {
- $xfer += $output->writeFieldBegin('preferredBatchQueue', TType::STRING, 5);
+ $xfer += $output->writeFieldBegin('preferredBatchQueue', TType::STRING, 6);
$xfer += $output->writeString($this->preferredBatchQueue);
$xfer += $output->writeFieldEnd();
}
if ($this->scratchLocation !== null) {
- $xfer += $output->writeFieldBegin('scratchLocation', TType::STRING, 6);
+ $xfer += $output->writeFieldBegin('scratchLocation', TType::STRING, 7);
$xfer += $output->writeString($this->scratchLocation);
$xfer += $output->writeFieldEnd();
}
if ($this->allocationProjectNumber !== null) {
- $xfer += $output->writeFieldBegin('allocationProjectNumber', TType::STRING, 7);
+ $xfer += $output->writeFieldBegin('allocationProjectNumber', TType::STRING, 8);
$xfer += $output->writeString($this->allocationProjectNumber);
$xfer += $output->writeFieldEnd();
}
http://git-wip-us.apache.org/repos/asf/airavata/blob/33b403fc/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/ComputeResourcePreference.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/ComputeResourcePreference.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/ComputeResourcePreference.java
index 26bd817..1661d3a 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/ComputeResourcePreference.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/ComputeResourcePreference.java
@@ -58,6 +58,9 @@ import org.slf4j.LoggerFactory;
* overridebyAiravata:
* If turned true, Airavata will override the preferences of better alternatives exist.
*
+ * loginUserName:
+ * If turned true, Airavata will override the preferences of better alternatives exist.
+ *
* preferredJobSubmissionProtocol:
* For resources with multiple job submission protocols, the gateway can pick a preferred option.
*
@@ -81,11 +84,12 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField COMPUTE_RESOURCE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("computeResourceId", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final org.apache.thrift.protocol.TField OVERRIDEBY_AIRAVATA_FIELD_DESC = new org.apache.thrift.protocol.TField("overridebyAiravata", org.apache.thrift.protocol.TType.BOOL, (short)2);
- private static final org.apache.thrift.protocol.TField PREFERRED_JOB_SUBMISSION_PROTOCOL_FIELD_DESC = new org.apache.thrift.protocol.TField("preferredJobSubmissionProtocol", org.apache.thrift.protocol.TType.I32, (short)3);
- private static final org.apache.thrift.protocol.TField PREFERRED_DATA_MOVEMENT_PROTOCOL_FIELD_DESC = new org.apache.thrift.protocol.TField("preferredDataMovementProtocol", org.apache.thrift.protocol.TType.I32, (short)4);
- private static final org.apache.thrift.protocol.TField PREFERRED_BATCH_QUEUE_FIELD_DESC = new org.apache.thrift.protocol.TField("preferredBatchQueue", org.apache.thrift.protocol.TType.STRING, (short)5);
- private static final org.apache.thrift.protocol.TField SCRATCH_LOCATION_FIELD_DESC = new org.apache.thrift.protocol.TField("scratchLocation", org.apache.thrift.protocol.TType.STRING, (short)6);
- private static final org.apache.thrift.protocol.TField ALLOCATION_PROJECT_NUMBER_FIELD_DESC = new org.apache.thrift.protocol.TField("allocationProjectNumber", org.apache.thrift.protocol.TType.STRING, (short)7);
+ private static final org.apache.thrift.protocol.TField LOGIN_USER_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("loginUserName", org.apache.thrift.protocol.TType.STRING, (short)3);
+ private static final org.apache.thrift.protocol.TField PREFERRED_JOB_SUBMISSION_PROTOCOL_FIELD_DESC = new org.apache.thrift.protocol.TField("preferredJobSubmissionProtocol", org.apache.thrift.protocol.TType.I32, (short)4);
+ private static final org.apache.thrift.protocol.TField PREFERRED_DATA_MOVEMENT_PROTOCOL_FIELD_DESC = new org.apache.thrift.protocol.TField("preferredDataMovementProtocol", org.apache.thrift.protocol.TType.I32, (short)5);
+ private static final org.apache.thrift.protocol.TField PREFERRED_BATCH_QUEUE_FIELD_DESC = new org.apache.thrift.protocol.TField("preferredBatchQueue", org.apache.thrift.protocol.TType.STRING, (short)6);
+ private static final org.apache.thrift.protocol.TField SCRATCH_LOCATION_FIELD_DESC = new org.apache.thrift.protocol.TField("scratchLocation", org.apache.thrift.protocol.TType.STRING, (short)7);
+ private static final org.apache.thrift.protocol.TField ALLOCATION_PROJECT_NUMBER_FIELD_DESC = new org.apache.thrift.protocol.TField("allocationProjectNumber", org.apache.thrift.protocol.TType.STRING, (short)8);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -95,6 +99,7 @@ import org.slf4j.LoggerFactory;
private String computeResourceId; // required
private boolean overridebyAiravata; // required
+ private String loginUserName; // optional
private org.apache.airavata.model.appcatalog.computeresource.JobSubmissionProtocol preferredJobSubmissionProtocol; // optional
private org.apache.airavata.model.appcatalog.computeresource.DataMovementProtocol preferredDataMovementProtocol; // optional
private String preferredBatchQueue; // optional
@@ -105,19 +110,20 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum {
COMPUTE_RESOURCE_ID((short)1, "computeResourceId"),
OVERRIDEBY_AIRAVATA((short)2, "overridebyAiravata"),
+ LOGIN_USER_NAME((short)3, "loginUserName"),
/**
*
* @see org.apache.airavata.model.appcatalog.computeresource.JobSubmissionProtocol
*/
- PREFERRED_JOB_SUBMISSION_PROTOCOL((short)3, "preferredJobSubmissionProtocol"),
+ PREFERRED_JOB_SUBMISSION_PROTOCOL((short)4, "preferredJobSubmissionProtocol"),
/**
*
* @see org.apache.airavata.model.appcatalog.computeresource.DataMovementProtocol
*/
- PREFERRED_DATA_MOVEMENT_PROTOCOL((short)4, "preferredDataMovementProtocol"),
- PREFERRED_BATCH_QUEUE((short)5, "preferredBatchQueue"),
- SCRATCH_LOCATION((short)6, "scratchLocation"),
- ALLOCATION_PROJECT_NUMBER((short)7, "allocationProjectNumber");
+ PREFERRED_DATA_MOVEMENT_PROTOCOL((short)5, "preferredDataMovementProtocol"),
+ PREFERRED_BATCH_QUEUE((short)6, "preferredBatchQueue"),
+ SCRATCH_LOCATION((short)7, "scratchLocation"),
+ ALLOCATION_PROJECT_NUMBER((short)8, "allocationProjectNumber");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -136,15 +142,17 @@ import org.slf4j.LoggerFactory;
return COMPUTE_RESOURCE_ID;
case 2: // OVERRIDEBY_AIRAVATA
return OVERRIDEBY_AIRAVATA;
- case 3: // PREFERRED_JOB_SUBMISSION_PROTOCOL
+ case 3: // LOGIN_USER_NAME
+ return LOGIN_USER_NAME;
+ case 4: // PREFERRED_JOB_SUBMISSION_PROTOCOL
return PREFERRED_JOB_SUBMISSION_PROTOCOL;
- case 4: // PREFERRED_DATA_MOVEMENT_PROTOCOL
+ case 5: // PREFERRED_DATA_MOVEMENT_PROTOCOL
return PREFERRED_DATA_MOVEMENT_PROTOCOL;
- case 5: // PREFERRED_BATCH_QUEUE
+ case 6: // PREFERRED_BATCH_QUEUE
return PREFERRED_BATCH_QUEUE;
- case 6: // SCRATCH_LOCATION
+ case 7: // SCRATCH_LOCATION
return SCRATCH_LOCATION;
- case 7: // ALLOCATION_PROJECT_NUMBER
+ case 8: // ALLOCATION_PROJECT_NUMBER
return ALLOCATION_PROJECT_NUMBER;
default:
return null;
@@ -188,7 +196,7 @@ import org.slf4j.LoggerFactory;
// isset id assignments
private static final int __OVERRIDEBYAIRAVATA_ISSET_ID = 0;
private byte __isset_bitfield = 0;
- private _Fields optionals[] = {_Fields.PREFERRED_JOB_SUBMISSION_PROTOCOL,_Fields.PREFERRED_DATA_MOVEMENT_PROTOCOL,_Fields.PREFERRED_BATCH_QUEUE,_Fields.SCRATCH_LOCATION,_Fields.ALLOCATION_PROJECT_NUMBER};
+ private _Fields optionals[] = {_Fields.LOGIN_USER_NAME,_Fields.PREFERRED_JOB_SUBMISSION_PROTOCOL,_Fields.PREFERRED_DATA_MOVEMENT_PROTOCOL,_Fields.PREFERRED_BATCH_QUEUE,_Fields.SCRATCH_LOCATION,_Fields.ALLOCATION_PROJECT_NUMBER};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -196,6 +204,8 @@ import org.slf4j.LoggerFactory;
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.OVERRIDEBY_AIRAVATA, new org.apache.thrift.meta_data.FieldMetaData("overridebyAiravata", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ tmpMap.put(_Fields.LOGIN_USER_NAME, new org.apache.thrift.meta_data.FieldMetaData("loginUserName", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.PREFERRED_JOB_SUBMISSION_PROTOCOL, new org.apache.thrift.meta_data.FieldMetaData("preferredJobSubmissionProtocol", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, org.apache.airavata.model.appcatalog.computeresource.JobSubmissionProtocol.class)));
tmpMap.put(_Fields.PREFERRED_DATA_MOVEMENT_PROTOCOL, new org.apache.thrift.meta_data.FieldMetaData("preferredDataMovementProtocol", org.apache.thrift.TFieldRequirementType.OPTIONAL,
@@ -234,6 +244,9 @@ import org.slf4j.LoggerFactory;
this.computeResourceId = other.computeResourceId;
}
this.overridebyAiravata = other.overridebyAiravata;
+ if (other.isSetLoginUserName()) {
+ this.loginUserName = other.loginUserName;
+ }
if (other.isSetPreferredJobSubmissionProtocol()) {
this.preferredJobSubmissionProtocol = other.preferredJobSubmissionProtocol;
}
@@ -260,6 +273,7 @@ import org.slf4j.LoggerFactory;
this.computeResourceId = null;
this.overridebyAiravata = true;
+ this.loginUserName = null;
this.preferredJobSubmissionProtocol = null;
this.preferredDataMovementProtocol = null;
this.preferredBatchQueue = null;
@@ -312,6 +326,29 @@ import org.slf4j.LoggerFactory;
__isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __OVERRIDEBYAIRAVATA_ISSET_ID, value);
}
+ public String getLoginUserName() {
+ return this.loginUserName;
+ }
+
+ public void setLoginUserName(String loginUserName) {
+ this.loginUserName = loginUserName;
+ }
+
+ public void unsetLoginUserName() {
+ this.loginUserName = null;
+ }
+
+ /** Returns true if field loginUserName is set (has been assigned a value) and false otherwise */
+ public boolean isSetLoginUserName() {
+ return this.loginUserName != null;
+ }
+
+ public void setLoginUserNameIsSet(boolean value) {
+ if (!value) {
+ this.loginUserName = null;
+ }
+ }
+
/**
*
* @see org.apache.airavata.model.appcatalog.computeresource.JobSubmissionProtocol
@@ -461,6 +498,14 @@ import org.slf4j.LoggerFactory;
}
break;
+ case LOGIN_USER_NAME:
+ if (value == null) {
+ unsetLoginUserName();
+ } else {
+ setLoginUserName((String)value);
+ }
+ break;
+
case PREFERRED_JOB_SUBMISSION_PROTOCOL:
if (value == null) {
unsetPreferredJobSubmissionProtocol();
@@ -512,6 +557,9 @@ import org.slf4j.LoggerFactory;
case OVERRIDEBY_AIRAVATA:
return Boolean.valueOf(isOverridebyAiravata());
+ case LOGIN_USER_NAME:
+ return getLoginUserName();
+
case PREFERRED_JOB_SUBMISSION_PROTOCOL:
return getPreferredJobSubmissionProtocol();
@@ -542,6 +590,8 @@ import org.slf4j.LoggerFactory;
return isSetComputeResourceId();
case OVERRIDEBY_AIRAVATA:
return isSetOverridebyAiravata();
+ case LOGIN_USER_NAME:
+ return isSetLoginUserName();
case PREFERRED_JOB_SUBMISSION_PROTOCOL:
return isSetPreferredJobSubmissionProtocol();
case PREFERRED_DATA_MOVEMENT_PROTOCOL:
@@ -587,6 +637,15 @@ import org.slf4j.LoggerFactory;
return false;
}
+ boolean this_present_loginUserName = true && this.isSetLoginUserName();
+ boolean that_present_loginUserName = true && that.isSetLoginUserName();
+ if (this_present_loginUserName || that_present_loginUserName) {
+ if (!(this_present_loginUserName && that_present_loginUserName))
+ return false;
+ if (!this.loginUserName.equals(that.loginUserName))
+ return false;
+ }
+
boolean this_present_preferredJobSubmissionProtocol = true && this.isSetPreferredJobSubmissionProtocol();
boolean that_present_preferredJobSubmissionProtocol = true && that.isSetPreferredJobSubmissionProtocol();
if (this_present_preferredJobSubmissionProtocol || that_present_preferredJobSubmissionProtocol) {
@@ -668,6 +727,16 @@ import org.slf4j.LoggerFactory;
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetLoginUserName()).compareTo(other.isSetLoginUserName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetLoginUserName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.loginUserName, other.loginUserName);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
lastComparison = Boolean.valueOf(isSetPreferredJobSubmissionProtocol()).compareTo(other.isSetPreferredJobSubmissionProtocol());
if (lastComparison != 0) {
return lastComparison;
@@ -749,6 +818,16 @@ import org.slf4j.LoggerFactory;
sb.append("overridebyAiravata:");
sb.append(this.overridebyAiravata);
first = false;
+ if (isSetLoginUserName()) {
+ if (!first) sb.append(", ");
+ sb.append("loginUserName:");
+ if (this.loginUserName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.loginUserName);
+ }
+ first = false;
+ }
if (isSetPreferredJobSubmissionProtocol()) {
if (!first) sb.append(", ");
sb.append("preferredJobSubmissionProtocol:");
@@ -868,7 +947,15 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
- case 3: // PREFERRED_JOB_SUBMISSION_PROTOCOL
+ case 3: // LOGIN_USER_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.loginUserName = iprot.readString();
+ struct.setLoginUserNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // PREFERRED_JOB_SUBMISSION_PROTOCOL
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.preferredJobSubmissionProtocol = org.apache.airavata.model.appcatalog.computeresource.JobSubmissionProtocol.findByValue(iprot.readI32());
struct.setPreferredJobSubmissionProtocolIsSet(true);
@@ -876,7 +963,7 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
- case 4: // PREFERRED_DATA_MOVEMENT_PROTOCOL
+ case 5: // PREFERRED_DATA_MOVEMENT_PROTOCOL
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.preferredDataMovementProtocol = org.apache.airavata.model.appcatalog.computeresource.DataMovementProtocol.findByValue(iprot.readI32());
struct.setPreferredDataMovementProtocolIsSet(true);
@@ -884,7 +971,7 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
- case 5: // PREFERRED_BATCH_QUEUE
+ case 6: // PREFERRED_BATCH_QUEUE
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.preferredBatchQueue = iprot.readString();
struct.setPreferredBatchQueueIsSet(true);
@@ -892,7 +979,7 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
- case 6: // SCRATCH_LOCATION
+ case 7: // SCRATCH_LOCATION
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.scratchLocation = iprot.readString();
struct.setScratchLocationIsSet(true);
@@ -900,7 +987,7 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
- case 7: // ALLOCATION_PROJECT_NUMBER
+ case 8: // ALLOCATION_PROJECT_NUMBER
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.allocationProjectNumber = iprot.readString();
struct.setAllocationProjectNumberIsSet(true);
@@ -929,6 +1016,13 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(OVERRIDEBY_AIRAVATA_FIELD_DESC);
oprot.writeBool(struct.overridebyAiravata);
oprot.writeFieldEnd();
+ if (struct.loginUserName != null) {
+ if (struct.isSetLoginUserName()) {
+ oprot.writeFieldBegin(LOGIN_USER_NAME_FIELD_DESC);
+ oprot.writeString(struct.loginUserName);
+ oprot.writeFieldEnd();
+ }
+ }
if (struct.preferredJobSubmissionProtocol != null) {
if (struct.isSetPreferredJobSubmissionProtocol()) {
oprot.writeFieldBegin(PREFERRED_JOB_SUBMISSION_PROTOCOL_FIELD_DESC);
@@ -984,22 +1078,28 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.computeResourceId);
oprot.writeBool(struct.overridebyAiravata);
BitSet optionals = new BitSet();
- if (struct.isSetPreferredJobSubmissionProtocol()) {
+ if (struct.isSetLoginUserName()) {
optionals.set(0);
}
- if (struct.isSetPreferredDataMovementProtocol()) {
+ if (struct.isSetPreferredJobSubmissionProtocol()) {
optionals.set(1);
}
- if (struct.isSetPreferredBatchQueue()) {
+ if (struct.isSetPreferredDataMovementProtocol()) {
optionals.set(2);
}
- if (struct.isSetScratchLocation()) {
+ if (struct.isSetPreferredBatchQueue()) {
optionals.set(3);
}
- if (struct.isSetAllocationProjectNumber()) {
+ if (struct.isSetScratchLocation()) {
optionals.set(4);
}
- oprot.writeBitSet(optionals, 5);
+ if (struct.isSetAllocationProjectNumber()) {
+ optionals.set(5);
+ }
+ oprot.writeBitSet(optionals, 6);
+ if (struct.isSetLoginUserName()) {
+ oprot.writeString(struct.loginUserName);
+ }
if (struct.isSetPreferredJobSubmissionProtocol()) {
oprot.writeI32(struct.preferredJobSubmissionProtocol.getValue());
}
@@ -1024,24 +1124,28 @@ import org.slf4j.LoggerFactory;
struct.setComputeResourceIdIsSet(true);
struct.overridebyAiravata = iprot.readBool();
struct.setOverridebyAiravataIsSet(true);
- BitSet incoming = iprot.readBitSet(5);
+ BitSet incoming = iprot.readBitSet(6);
if (incoming.get(0)) {
+ struct.loginUserName = iprot.readString();
+ struct.setLoginUserNameIsSet(true);
+ }
+ if (incoming.get(1)) {
struct.preferredJobSubmissionProtocol = org.apache.airavata.model.appcatalog.computeresource.JobSubmissionProtocol.findByValue(iprot.readI32());
struct.setPreferredJobSubmissionProtocolIsSet(true);
}
- if (incoming.get(1)) {
+ if (incoming.get(2)) {
struct.preferredDataMovementProtocol = org.apache.airavata.model.appcatalog.computeresource.DataMovementProtocol.findByValue(iprot.readI32());
struct.setPreferredDataMovementProtocolIsSet(true);
}
- if (incoming.get(2)) {
+ if (incoming.get(3)) {
struct.preferredBatchQueue = iprot.readString();
struct.setPreferredBatchQueueIsSet(true);
}
- if (incoming.get(3)) {
+ if (incoming.get(4)) {
struct.scratchLocation = iprot.readString();
struct.setScratchLocationIsSet(true);
}
- if (incoming.get(4)) {
+ if (incoming.get(5)) {
struct.allocationProjectNumber = iprot.readString();
struct.setAllocationProjectNumberIsSet(true);
}
http://git-wip-us.apache.org/repos/asf/airavata/blob/33b403fc/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/GatewayResourceProfile.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/GatewayResourceProfile.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/GatewayResourceProfile.java
index fccc2be..1c317eb 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/GatewayResourceProfile.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/GatewayResourceProfile.java
@@ -55,12 +55,6 @@ import org.slf4j.LoggerFactory;
* gatewayID:
* Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration.
*
- * gatewayName:
- * Name of the Gateway.
- *
- * gatewayDescription:
- * A user friendly description of the gateway.
- *
* computeResourcePreferences:
* List of resource preferences for each of the registered compute resources.
*
[3/5] airavata git commit: Stubs for credential store api methods -
AIRAVATA-1616
Posted by sm...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/33b403fc/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
index a1ce19d..32390a3 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
@@ -39,6 +39,9 @@ class AiravataIf {
virtual bool deleteGateway(const std::string& gatewayId) = 0;
virtual void getAllGateways(std::vector< ::apache::airavata::model::workspace::Gateway> & _return) = 0;
virtual bool isGatewayExist(const std::string& gatewayId) = 0;
+ virtual void generateAndRegisterSSHKeys(std::string& _return, const std::string& gatewayId, const std::string& userName) = 0;
+ virtual void getSSHPubKey(std::string& _return, const std::string& airavataCredStoreToken) = 0;
+ virtual void getAllUserSSHPubKeys(std::map<std::string, std::string> & _return, const std::string& userName) = 0;
virtual void createProject(std::string& _return, const ::apache::airavata::model::workspace::Project& project) = 0;
virtual void updateProject(const std::string& projectId, const ::apache::airavata::model::workspace::Project& updatedProject) = 0;
virtual void getProject( ::apache::airavata::model::workspace::Project& _return, const std::string& projectId) = 0;
@@ -196,6 +199,15 @@ class AiravataNull : virtual public AiravataIf {
bool _return = false;
return _return;
}
+ void generateAndRegisterSSHKeys(std::string& /* _return */, const std::string& /* gatewayId */, const std::string& /* userName */) {
+ return;
+ }
+ void getSSHPubKey(std::string& /* _return */, const std::string& /* airavataCredStoreToken */) {
+ return;
+ }
+ void getAllUserSSHPubKeys(std::map<std::string, std::string> & /* _return */, const std::string& /* userName */) {
+ return;
+ }
void createProject(std::string& /* _return */, const ::apache::airavata::model::workspace::Project& /* project */) {
return;
}
@@ -1452,6 +1464,410 @@ class Airavata_isGatewayExist_presult {
};
+class Airavata_generateAndRegisterSSHKeys_args {
+ public:
+
+ Airavata_generateAndRegisterSSHKeys_args() : gatewayId(), userName() {
+ }
+
+ virtual ~Airavata_generateAndRegisterSSHKeys_args() throw() {}
+
+ std::string gatewayId;
+ std::string userName;
+
+ void __set_gatewayId(const std::string& val) {
+ gatewayId = val;
+ }
+
+ void __set_userName(const std::string& val) {
+ userName = val;
+ }
+
+ bool operator == (const Airavata_generateAndRegisterSSHKeys_args & rhs) const
+ {
+ if (!(gatewayId == rhs.gatewayId))
+ return false;
+ if (!(userName == rhs.userName))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_generateAndRegisterSSHKeys_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_generateAndRegisterSSHKeys_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class Airavata_generateAndRegisterSSHKeys_pargs {
+ public:
+
+
+ virtual ~Airavata_generateAndRegisterSSHKeys_pargs() throw() {}
+
+ const std::string* gatewayId;
+ const std::string* userName;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_generateAndRegisterSSHKeys_result__isset {
+ _Airavata_generateAndRegisterSSHKeys_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_generateAndRegisterSSHKeys_result__isset;
+
+class Airavata_generateAndRegisterSSHKeys_result {
+ public:
+
+ Airavata_generateAndRegisterSSHKeys_result() : success() {
+ }
+
+ virtual ~Airavata_generateAndRegisterSSHKeys_result() throw() {}
+
+ std::string success;
+ ::apache::airavata::api::error::InvalidRequestException ire;
+ ::apache::airavata::api::error::AiravataClientException ace;
+ ::apache::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_generateAndRegisterSSHKeys_result__isset __isset;
+
+ void __set_success(const std::string& val) {
+ success = val;
+ }
+
+ void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) {
+ ire = val;
+ }
+
+ void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) {
+ ace = val;
+ }
+
+ void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) {
+ ase = val;
+ }
+
+ bool operator == (const Airavata_generateAndRegisterSSHKeys_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(ire == rhs.ire))
+ return false;
+ if (!(ace == rhs.ace))
+ return false;
+ if (!(ase == rhs.ase))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_generateAndRegisterSSHKeys_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_generateAndRegisterSSHKeys_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_generateAndRegisterSSHKeys_presult__isset {
+ _Airavata_generateAndRegisterSSHKeys_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_generateAndRegisterSSHKeys_presult__isset;
+
+class Airavata_generateAndRegisterSSHKeys_presult {
+ public:
+
+
+ virtual ~Airavata_generateAndRegisterSSHKeys_presult() throw() {}
+
+ std::string* success;
+ ::apache::airavata::api::error::InvalidRequestException ire;
+ ::apache::airavata::api::error::AiravataClientException ace;
+ ::apache::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_generateAndRegisterSSHKeys_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+
+class Airavata_getSSHPubKey_args {
+ public:
+
+ Airavata_getSSHPubKey_args() : airavataCredStoreToken() {
+ }
+
+ virtual ~Airavata_getSSHPubKey_args() throw() {}
+
+ std::string airavataCredStoreToken;
+
+ void __set_airavataCredStoreToken(const std::string& val) {
+ airavataCredStoreToken = val;
+ }
+
+ bool operator == (const Airavata_getSSHPubKey_args & rhs) const
+ {
+ if (!(airavataCredStoreToken == rhs.airavataCredStoreToken))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_getSSHPubKey_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_getSSHPubKey_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class Airavata_getSSHPubKey_pargs {
+ public:
+
+
+ virtual ~Airavata_getSSHPubKey_pargs() throw() {}
+
+ const std::string* airavataCredStoreToken;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_getSSHPubKey_result__isset {
+ _Airavata_getSSHPubKey_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_getSSHPubKey_result__isset;
+
+class Airavata_getSSHPubKey_result {
+ public:
+
+ Airavata_getSSHPubKey_result() : success() {
+ }
+
+ virtual ~Airavata_getSSHPubKey_result() throw() {}
+
+ std::string success;
+ ::apache::airavata::api::error::InvalidRequestException ire;
+ ::apache::airavata::api::error::AiravataClientException ace;
+ ::apache::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_getSSHPubKey_result__isset __isset;
+
+ void __set_success(const std::string& val) {
+ success = val;
+ }
+
+ void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) {
+ ire = val;
+ }
+
+ void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) {
+ ace = val;
+ }
+
+ void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) {
+ ase = val;
+ }
+
+ bool operator == (const Airavata_getSSHPubKey_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(ire == rhs.ire))
+ return false;
+ if (!(ace == rhs.ace))
+ return false;
+ if (!(ase == rhs.ase))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_getSSHPubKey_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_getSSHPubKey_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_getSSHPubKey_presult__isset {
+ _Airavata_getSSHPubKey_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_getSSHPubKey_presult__isset;
+
+class Airavata_getSSHPubKey_presult {
+ public:
+
+
+ virtual ~Airavata_getSSHPubKey_presult() throw() {}
+
+ std::string* success;
+ ::apache::airavata::api::error::InvalidRequestException ire;
+ ::apache::airavata::api::error::AiravataClientException ace;
+ ::apache::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_getSSHPubKey_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+
+class Airavata_getAllUserSSHPubKeys_args {
+ public:
+
+ Airavata_getAllUserSSHPubKeys_args() : userName() {
+ }
+
+ virtual ~Airavata_getAllUserSSHPubKeys_args() throw() {}
+
+ std::string userName;
+
+ void __set_userName(const std::string& val) {
+ userName = val;
+ }
+
+ bool operator == (const Airavata_getAllUserSSHPubKeys_args & rhs) const
+ {
+ if (!(userName == rhs.userName))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_getAllUserSSHPubKeys_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_getAllUserSSHPubKeys_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class Airavata_getAllUserSSHPubKeys_pargs {
+ public:
+
+
+ virtual ~Airavata_getAllUserSSHPubKeys_pargs() throw() {}
+
+ const std::string* userName;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_getAllUserSSHPubKeys_result__isset {
+ _Airavata_getAllUserSSHPubKeys_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_getAllUserSSHPubKeys_result__isset;
+
+class Airavata_getAllUserSSHPubKeys_result {
+ public:
+
+ Airavata_getAllUserSSHPubKeys_result() {
+ }
+
+ virtual ~Airavata_getAllUserSSHPubKeys_result() throw() {}
+
+ std::map<std::string, std::string> success;
+ ::apache::airavata::api::error::InvalidRequestException ire;
+ ::apache::airavata::api::error::AiravataClientException ace;
+ ::apache::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_getAllUserSSHPubKeys_result__isset __isset;
+
+ void __set_success(const std::map<std::string, std::string> & val) {
+ success = val;
+ }
+
+ void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) {
+ ire = val;
+ }
+
+ void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) {
+ ace = val;
+ }
+
+ void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) {
+ ase = val;
+ }
+
+ bool operator == (const Airavata_getAllUserSSHPubKeys_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(ire == rhs.ire))
+ return false;
+ if (!(ace == rhs.ace))
+ return false;
+ if (!(ase == rhs.ase))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_getAllUserSSHPubKeys_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_getAllUserSSHPubKeys_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_getAllUserSSHPubKeys_presult__isset {
+ _Airavata_getAllUserSSHPubKeys_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_getAllUserSSHPubKeys_presult__isset;
+
+class Airavata_getAllUserSSHPubKeys_presult {
+ public:
+
+
+ virtual ~Airavata_getAllUserSSHPubKeys_presult() throw() {}
+
+ std::map<std::string, std::string> * success;
+ ::apache::airavata::api::error::InvalidRequestException ire;
+ ::apache::airavata::api::error::AiravataClientException ace;
+ ::apache::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_getAllUserSSHPubKeys_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+
class Airavata_createProject_args {
public:
@@ -15757,6 +16173,15 @@ class AiravataClient : virtual public AiravataIf {
bool isGatewayExist(const std::string& gatewayId);
void send_isGatewayExist(const std::string& gatewayId);
bool recv_isGatewayExist();
+ void generateAndRegisterSSHKeys(std::string& _return, const std::string& gatewayId, const std::string& userName);
+ void send_generateAndRegisterSSHKeys(const std::string& gatewayId, const std::string& userName);
+ void recv_generateAndRegisterSSHKeys(std::string& _return);
+ void getSSHPubKey(std::string& _return, const std::string& airavataCredStoreToken);
+ void send_getSSHPubKey(const std::string& airavataCredStoreToken);
+ void recv_getSSHPubKey(std::string& _return);
+ void getAllUserSSHPubKeys(std::map<std::string, std::string> & _return, const std::string& userName);
+ void send_getAllUserSSHPubKeys(const std::string& userName);
+ void recv_getAllUserSSHPubKeys(std::map<std::string, std::string> & _return);
void createProject(std::string& _return, const ::apache::airavata::model::workspace::Project& project);
void send_createProject(const ::apache::airavata::model::workspace::Project& project);
void recv_createProject(std::string& _return);
@@ -16094,6 +16519,9 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor {
void process_deleteGateway(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getAllGateways(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_isGatewayExist(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_generateAndRegisterSSHKeys(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_getSSHPubKey(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_getAllUserSSHPubKeys(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_createProject(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_updateProject(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getProject(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
@@ -16209,6 +16637,9 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor {
processMap_["deleteGateway"] = &AiravataProcessor::process_deleteGateway;
processMap_["getAllGateways"] = &AiravataProcessor::process_getAllGateways;
processMap_["isGatewayExist"] = &AiravataProcessor::process_isGatewayExist;
+ processMap_["generateAndRegisterSSHKeys"] = &AiravataProcessor::process_generateAndRegisterSSHKeys;
+ processMap_["getSSHPubKey"] = &AiravataProcessor::process_getSSHPubKey;
+ processMap_["getAllUserSSHPubKeys"] = &AiravataProcessor::process_getAllUserSSHPubKeys;
processMap_["createProject"] = &AiravataProcessor::process_createProject;
processMap_["updateProject"] = &AiravataProcessor::process_updateProject;
processMap_["getProject"] = &AiravataProcessor::process_getProject;
@@ -16409,6 +16840,36 @@ class AiravataMultiface : virtual public AiravataIf {
return ifaces_[i]->isGatewayExist(gatewayId);
}
+ void generateAndRegisterSSHKeys(std::string& _return, const std::string& gatewayId, const std::string& userName) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->generateAndRegisterSSHKeys(_return, gatewayId, userName);
+ }
+ ifaces_[i]->generateAndRegisterSSHKeys(_return, gatewayId, userName);
+ return;
+ }
+
+ void getSSHPubKey(std::string& _return, const std::string& airavataCredStoreToken) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->getSSHPubKey(_return, airavataCredStoreToken);
+ }
+ ifaces_[i]->getSSHPubKey(_return, airavataCredStoreToken);
+ return;
+ }
+
+ void getAllUserSSHPubKeys(std::map<std::string, std::string> & _return, const std::string& userName) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->getAllUserSSHPubKeys(_return, userName);
+ }
+ ifaces_[i]->getAllUserSSHPubKeys(_return, userName);
+ return;
+ }
+
void createProject(std::string& _return, const ::apache::airavata::model::workspace::Project& project) {
size_t sz = ifaces_.size();
size_t i = 0;
http://git-wip-us.apache.org/repos/asf/airavata/blob/33b403fc/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
index 42f63a2..ef13e57 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
@@ -74,6 +74,21 @@ class AiravataHandler : virtual public AiravataIf {
printf("isGatewayExist\n");
}
+ void generateAndRegisterSSHKeys(std::string& _return, const std::string& gatewayId, const std::string& userName) {
+ // Your implementation goes here
+ printf("generateAndRegisterSSHKeys\n");
+ }
+
+ void getSSHPubKey(std::string& _return, const std::string& airavataCredStoreToken) {
+ // Your implementation goes here
+ printf("getSSHPubKey\n");
+ }
+
+ void getAllUserSSHPubKeys(std::map<std::string, std::string> & _return, const std::string& userName) {
+ // Your implementation goes here
+ printf("getAllUserSSHPubKeys\n");
+ }
+
void createProject(std::string& _return, const ::apache::airavata::model::workspace::Project& project) {
// Your implementation goes here
printf("createProject\n");
http://git-wip-us.apache.org/repos/asf/airavata/blob/33b403fc/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.cpp
index 87fd134..1c465e4 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.cpp
@@ -27,8 +27,8 @@
namespace apache { namespace airavata { namespace model { namespace appcatalog { namespace gatewayprofile {
-const char* ComputeResourcePreference::ascii_fingerprint = "365108C84A2E160D53CD17C2A7F06F5C";
-const uint8_t ComputeResourcePreference::binary_fingerprint[16] = {0x36,0x51,0x08,0xC8,0x4A,0x2E,0x16,0x0D,0x53,0xCD,0x17,0xC2,0xA7,0xF0,0x6F,0x5C};
+const char* ComputeResourcePreference::ascii_fingerprint = "D89E0E13D04B60B99B78496AC9B85D52";
+const uint8_t ComputeResourcePreference::binary_fingerprint[16] = {0xD8,0x9E,0x0E,0x13,0xD0,0x4B,0x60,0xB9,0x9B,0x78,0x49,0x6A,0xC9,0xB8,0x5D,0x52};
uint32_t ComputeResourcePreference::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -69,6 +69,14 @@ uint32_t ComputeResourcePreference::read(::apache::thrift::protocol::TProtocol*
}
break;
case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->loginUserName);
+ this->__isset.loginUserName = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
if (ftype == ::apache::thrift::protocol::T_I32) {
int32_t ecast0;
xfer += iprot->readI32(ecast0);
@@ -78,7 +86,7 @@ uint32_t ComputeResourcePreference::read(::apache::thrift::protocol::TProtocol*
xfer += iprot->skip(ftype);
}
break;
- case 4:
+ case 5:
if (ftype == ::apache::thrift::protocol::T_I32) {
int32_t ecast1;
xfer += iprot->readI32(ecast1);
@@ -88,7 +96,7 @@ uint32_t ComputeResourcePreference::read(::apache::thrift::protocol::TProtocol*
xfer += iprot->skip(ftype);
}
break;
- case 5:
+ case 6:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->preferredBatchQueue);
this->__isset.preferredBatchQueue = true;
@@ -96,7 +104,7 @@ uint32_t ComputeResourcePreference::read(::apache::thrift::protocol::TProtocol*
xfer += iprot->skip(ftype);
}
break;
- case 6:
+ case 7:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->scratchLocation);
this->__isset.scratchLocation = true;
@@ -104,7 +112,7 @@ uint32_t ComputeResourcePreference::read(::apache::thrift::protocol::TProtocol*
xfer += iprot->skip(ftype);
}
break;
- case 7:
+ case 8:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->allocationProjectNumber);
this->__isset.allocationProjectNumber = true;
@@ -140,28 +148,33 @@ uint32_t ComputeResourcePreference::write(::apache::thrift::protocol::TProtocol*
xfer += oprot->writeBool(this->overridebyAiravata);
xfer += oprot->writeFieldEnd();
+ if (this->__isset.loginUserName) {
+ xfer += oprot->writeFieldBegin("loginUserName", ::apache::thrift::protocol::T_STRING, 3);
+ xfer += oprot->writeString(this->loginUserName);
+ xfer += oprot->writeFieldEnd();
+ }
if (this->__isset.preferredJobSubmissionProtocol) {
- xfer += oprot->writeFieldBegin("preferredJobSubmissionProtocol", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeFieldBegin("preferredJobSubmissionProtocol", ::apache::thrift::protocol::T_I32, 4);
xfer += oprot->writeI32((int32_t)this->preferredJobSubmissionProtocol);
xfer += oprot->writeFieldEnd();
}
if (this->__isset.preferredDataMovementProtocol) {
- xfer += oprot->writeFieldBegin("preferredDataMovementProtocol", ::apache::thrift::protocol::T_I32, 4);
+ xfer += oprot->writeFieldBegin("preferredDataMovementProtocol", ::apache::thrift::protocol::T_I32, 5);
xfer += oprot->writeI32((int32_t)this->preferredDataMovementProtocol);
xfer += oprot->writeFieldEnd();
}
if (this->__isset.preferredBatchQueue) {
- xfer += oprot->writeFieldBegin("preferredBatchQueue", ::apache::thrift::protocol::T_STRING, 5);
+ xfer += oprot->writeFieldBegin("preferredBatchQueue", ::apache::thrift::protocol::T_STRING, 6);
xfer += oprot->writeString(this->preferredBatchQueue);
xfer += oprot->writeFieldEnd();
}
if (this->__isset.scratchLocation) {
- xfer += oprot->writeFieldBegin("scratchLocation", ::apache::thrift::protocol::T_STRING, 6);
+ xfer += oprot->writeFieldBegin("scratchLocation", ::apache::thrift::protocol::T_STRING, 7);
xfer += oprot->writeString(this->scratchLocation);
xfer += oprot->writeFieldEnd();
}
if (this->__isset.allocationProjectNumber) {
- xfer += oprot->writeFieldBegin("allocationProjectNumber", ::apache::thrift::protocol::T_STRING, 7);
+ xfer += oprot->writeFieldBegin("allocationProjectNumber", ::apache::thrift::protocol::T_STRING, 8);
xfer += oprot->writeString(this->allocationProjectNumber);
xfer += oprot->writeFieldEnd();
}
@@ -174,6 +187,7 @@ void swap(ComputeResourcePreference &a, ComputeResourcePreference &b) {
using ::std::swap;
swap(a.computeResourceId, b.computeResourceId);
swap(a.overridebyAiravata, b.overridebyAiravata);
+ swap(a.loginUserName, b.loginUserName);
swap(a.preferredJobSubmissionProtocol, b.preferredJobSubmissionProtocol);
swap(a.preferredDataMovementProtocol, b.preferredDataMovementProtocol);
swap(a.preferredBatchQueue, b.preferredBatchQueue);
@@ -182,8 +196,8 @@ void swap(ComputeResourcePreference &a, ComputeResourcePreference &b) {
swap(a.__isset, b.__isset);
}
-const char* GatewayResourceProfile::ascii_fingerprint = "2C13C97D8E01026228E6E378E58505CC";
-const uint8_t GatewayResourceProfile::binary_fingerprint[16] = {0x2C,0x13,0xC9,0x7D,0x8E,0x01,0x02,0x62,0x28,0xE6,0xE3,0x78,0xE5,0x85,0x05,0xCC};
+const char* GatewayResourceProfile::ascii_fingerprint = "106DE1CD0F7026F6471DE8DAF360BE03";
+const uint8_t GatewayResourceProfile::binary_fingerprint[16] = {0x10,0x6D,0xE1,0xCD,0x0F,0x70,0x26,0xF6,0x47,0x1D,0xE8,0xDA,0xF3,0x60,0xBE,0x03};
uint32_t GatewayResourceProfile::read(::apache::thrift::protocol::TProtocol* iprot) {
http://git-wip-us.apache.org/repos/asf/airavata/blob/33b403fc/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.h
index 231d73f..c664087 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.h
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.h
@@ -36,7 +36,8 @@
namespace apache { namespace airavata { namespace model { namespace appcatalog { namespace gatewayprofile {
typedef struct _ComputeResourcePreference__isset {
- _ComputeResourcePreference__isset() : preferredJobSubmissionProtocol(false), preferredDataMovementProtocol(false), preferredBatchQueue(false), scratchLocation(false), allocationProjectNumber(false) {}
+ _ComputeResourcePreference__isset() : loginUserName(false), preferredJobSubmissionProtocol(false), preferredDataMovementProtocol(false), preferredBatchQueue(false), scratchLocation(false), allocationProjectNumber(false) {}
+ bool loginUserName;
bool preferredJobSubmissionProtocol;
bool preferredDataMovementProtocol;
bool preferredBatchQueue;
@@ -47,16 +48,17 @@ typedef struct _ComputeResourcePreference__isset {
class ComputeResourcePreference {
public:
- static const char* ascii_fingerprint; // = "365108C84A2E160D53CD17C2A7F06F5C";
- static const uint8_t binary_fingerprint[16]; // = {0x36,0x51,0x08,0xC8,0x4A,0x2E,0x16,0x0D,0x53,0xCD,0x17,0xC2,0xA7,0xF0,0x6F,0x5C};
+ static const char* ascii_fingerprint; // = "D89E0E13D04B60B99B78496AC9B85D52";
+ static const uint8_t binary_fingerprint[16]; // = {0xD8,0x9E,0x0E,0x13,0xD0,0x4B,0x60,0xB9,0x9B,0x78,0x49,0x6A,0xC9,0xB8,0x5D,0x52};
- ComputeResourcePreference() : computeResourceId(), overridebyAiravata(true), preferredJobSubmissionProtocol(( ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type)0), preferredDataMovementProtocol(( ::apache::airavata::model::appcatalog::computeresource::DataMovementProtocol::type)0), preferredBatchQueue(), scratchLocation(), allocationProjectNumber() {
+ ComputeResourcePreference() : computeResourceId(), overridebyAiravata(true), loginUserName(), preferredJobSubmissionProtocol(( ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type)0), preferredDataMovementProtocol(( ::apache::airavata::model::appcatalog::computeresource::DataMovementProtocol::type)0), preferredBatchQueue(), scratchLocation(), allocationProjectNumber() {
}
virtual ~ComputeResourcePreference() throw() {}
std::string computeResourceId;
bool overridebyAiravata;
+ std::string loginUserName;
::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type preferredJobSubmissionProtocol;
::apache::airavata::model::appcatalog::computeresource::DataMovementProtocol::type preferredDataMovementProtocol;
std::string preferredBatchQueue;
@@ -73,6 +75,11 @@ class ComputeResourcePreference {
overridebyAiravata = val;
}
+ void __set_loginUserName(const std::string& val) {
+ loginUserName = val;
+ __isset.loginUserName = true;
+ }
+
void __set_preferredJobSubmissionProtocol(const ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type val) {
preferredJobSubmissionProtocol = val;
__isset.preferredJobSubmissionProtocol = true;
@@ -104,6 +111,10 @@ class ComputeResourcePreference {
return false;
if (!(overridebyAiravata == rhs.overridebyAiravata))
return false;
+ if (__isset.loginUserName != rhs.__isset.loginUserName)
+ return false;
+ else if (__isset.loginUserName && !(loginUserName == rhs.loginUserName))
+ return false;
if (__isset.preferredJobSubmissionProtocol != rhs.__isset.preferredJobSubmissionProtocol)
return false;
else if (__isset.preferredJobSubmissionProtocol && !(preferredJobSubmissionProtocol == rhs.preferredJobSubmissionProtocol))
@@ -147,8 +158,8 @@ typedef struct _GatewayResourceProfile__isset {
class GatewayResourceProfile {
public:
- static const char* ascii_fingerprint; // = "2C13C97D8E01026228E6E378E58505CC";
- static const uint8_t binary_fingerprint[16]; // = {0x2C,0x13,0xC9,0x7D,0x8E,0x01,0x02,0x62,0x28,0xE6,0xE3,0x78,0xE5,0x85,0x05,0xCC};
+ static const char* ascii_fingerprint; // = "106DE1CD0F7026F6471DE8DAF360BE03";
+ static const uint8_t binary_fingerprint[16]; // = {0x10,0x6D,0xE1,0xCD,0x0F,0x70,0x26,0xF6,0x47,0x1D,0xE8,0xDA,0xF3,0x60,0xBE,0x03};
GatewayResourceProfile() : gatewayID() {
}
[5/5] airavata git commit: Stubs for credential store api methods -
AIRAVATA-1616
Posted by sm...@apache.org.
Stubs for credential store api methods - AIRAVATA-1616
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/33b403fc
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/33b403fc
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/33b403fc
Branch: refs/heads/master
Commit: 33b403fc793d0e5d373a86b48982bde09dfe6b76
Parents: f9f63a0
Author: Suresh Marru <sm...@apache.org>
Authored: Tue Mar 3 12:34:49 2015 -0500
Committer: Suresh Marru <sm...@apache.org>
Committed: Tue Mar 3 12:34:49 2015 -0500
----------------------------------------------------------------------
.../main/resources/lib/airavata/Airavata.cpp | 2356 +++++++++++++-----
.../src/main/resources/lib/airavata/Airavata.h | 461 ++++
.../lib/airavata/Airavata_server.skeleton.cpp | 15 +
.../gatewayResourceProfileModel_types.cpp | 40 +-
.../gatewayResourceProfileModel_types.h | 23 +-
.../resources/lib/Airavata/API/Airavata.php | 1648 +++++++++---
.../Model/AppCatalog/GatewayProfile/Types.php | 46 +-
.../ComputeResourcePreference.java | 168 +-
.../gatewayprofile/GatewayResourceProfile.java | 6 -
9 files changed, 3687 insertions(+), 1076 deletions(-)
----------------------------------------------------------------------
[2/5] airavata git commit: Stubs for credential store api methods -
AIRAVATA-1616
Posted by sm...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/33b403fc/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
index 9ed696f..9c65026 100644
--- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
+++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
@@ -24,6 +24,9 @@ interface AiravataIf {
public function deleteGateway($gatewayId);
public function getAllGateways();
public function isGatewayExist($gatewayId);
+ public function generateAndRegisterSSHKeys($gatewayId, $userName);
+ public function getSSHPubKey($airavataCredStoreToken);
+ public function getAllUserSSHPubKeys($userName);
public function createProject(\Airavata\Model\Workspace\Project $project);
public function updateProject($projectId, \Airavata\Model\Workspace\Project $updatedProject);
public function getProject($projectId);
@@ -558,6 +561,187 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("isGatewayExist failed: unknown result");
}
+ public function generateAndRegisterSSHKeys($gatewayId, $userName)
+ {
+ $this->send_generateAndRegisterSSHKeys($gatewayId, $userName);
+ return $this->recv_generateAndRegisterSSHKeys();
+ }
+
+ public function send_generateAndRegisterSSHKeys($gatewayId, $userName)
+ {
+ $args = new \Airavata\API\Airavata_generateAndRegisterSSHKeys_args();
+ $args->gatewayId = $gatewayId;
+ $args->userName = $userName;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'generateAndRegisterSSHKeys', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('generateAndRegisterSSHKeys', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_generateAndRegisterSSHKeys()
+ {
+ $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_generateAndRegisterSSHKeys_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_generateAndRegisterSSHKeys_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;
+ }
+ throw new \Exception("generateAndRegisterSSHKeys failed: unknown result");
+ }
+
+ public function getSSHPubKey($airavataCredStoreToken)
+ {
+ $this->send_getSSHPubKey($airavataCredStoreToken);
+ return $this->recv_getSSHPubKey();
+ }
+
+ public function send_getSSHPubKey($airavataCredStoreToken)
+ {
+ $args = new \Airavata\API\Airavata_getSSHPubKey_args();
+ $args->airavataCredStoreToken = $airavataCredStoreToken;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getSSHPubKey', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getSSHPubKey', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getSSHPubKey()
+ {
+ $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_getSSHPubKey_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_getSSHPubKey_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;
+ }
+ throw new \Exception("getSSHPubKey failed: unknown result");
+ }
+
+ public function getAllUserSSHPubKeys($userName)
+ {
+ $this->send_getAllUserSSHPubKeys($userName);
+ return $this->recv_getAllUserSSHPubKeys();
+ }
+
+ public function send_getAllUserSSHPubKeys($userName)
+ {
+ $args = new \Airavata\API\Airavata_getAllUserSSHPubKeys_args();
+ $args->userName = $userName;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getAllUserSSHPubKeys', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getAllUserSSHPubKeys', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getAllUserSSHPubKeys()
+ {
+ $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_getAllUserSSHPubKeys_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_getAllUserSSHPubKeys_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;
+ }
+ throw new \Exception("getAllUserSSHPubKeys failed: unknown result");
+ }
+
public function createProject(\Airavata\Model\Workspace\Project $project)
{
$this->send_createProject($project);
@@ -7607,7 +7791,648 @@ class Airavata_getGateway_args {
}
-class Airavata_getGateway_result {
+class Airavata_getGateway_result {
+ static $_TSPEC;
+
+ public $success = null;
+ public $ire = null;
+ public $ace = null;
+ public $ase = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Workspace\Gateway',
+ ),
+ 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',
+ ),
+ );
+ }
+ 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'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getGateway_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::STRUCT) {
+ $this->success = new \Airavata\Model\Workspace\Gateway();
+ $xfer += $this->success->read($input);
+ } 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;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_getGateway_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->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();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_deleteGateway_args {
+ static $_TSPEC;
+
+ public $gatewayId = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'gatewayId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['gatewayId'])) {
+ $this->gatewayId = $vals['gatewayId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_deleteGateway_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::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_deleteGateway_args');
+ if ($this->gatewayId !== null) {
+ $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 1);
+ $xfer += $output->writeString($this->gatewayId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_deleteGateway_result {
+ static $_TSPEC;
+
+ public $success = null;
+ public $ire = null;
+ public $ace = null;
+ public $ase = 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',
+ ),
+ );
+ }
+ 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'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_deleteGateway_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;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_deleteGateway_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();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_getAllGateways_args {
+ static $_TSPEC;
+
+
+ public function __construct() {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ );
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getAllGateways_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)
+ {
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_getAllGateways_args');
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_getAllGateways_result {
+ static $_TSPEC;
+
+ public $success = null;
+ public $ire = null;
+ public $ace = null;
+ public $ase = 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\Workspace\Gateway',
+ ),
+ ),
+ 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',
+ ),
+ );
+ }
+ 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'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getAllGateways_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();
+ $_size0 = 0;
+ $_etype3 = 0;
+ $xfer += $input->readListBegin($_etype3, $_size0);
+ for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
+ {
+ $elem5 = null;
+ $elem5 = new \Airavata\Model\Workspace\Gateway();
+ $xfer += $elem5->read($input);
+ $this->success []= $elem5;
+ }
+ $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;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_getAllGateways_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 $iter6)
+ {
+ $xfer += $iter6->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();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_isGatewayExist_args {
+ static $_TSPEC;
+
+ public $gatewayId = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'gatewayId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['gatewayId'])) {
+ $this->gatewayId = $vals['gatewayId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_isGatewayExist_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::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_isGatewayExist_args');
+ if ($this->gatewayId !== null) {
+ $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 1);
+ $xfer += $output->writeString($this->gatewayId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_isGatewayExist_result {
static $_TSPEC;
public $success = null;
@@ -7620,8 +8445,7 @@ class Airavata_getGateway_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\Workspace\Gateway',
+ 'type' => TType::BOOL,
),
1 => array(
'var' => 'ire',
@@ -7657,7 +8481,7 @@ class Airavata_getGateway_result {
}
public function getName() {
- return 'Airavata_getGateway_result';
+ return 'Airavata_isGatewayExist_result';
}
public function read($input)
@@ -7676,9 +8500,8 @@ class Airavata_getGateway_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::STRUCT) {
- $this->success = new \Airavata\Model\Workspace\Gateway();
- $xfer += $this->success->read($input);
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -7719,13 +8542,10 @@ class Airavata_getGateway_result {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_getGateway_result');
+ $xfer += $output->writeStructBegin('Airavata_isGatewayExist_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) {
@@ -7750,10 +8570,11 @@ class Airavata_getGateway_result {
}
-class Airavata_deleteGateway_args {
+class Airavata_generateAndRegisterSSHKeys_args {
static $_TSPEC;
public $gatewayId = null;
+ public $userName = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -7762,17 +8583,24 @@ class Airavata_deleteGateway_args {
'var' => 'gatewayId',
'type' => TType::STRING,
),
+ 2 => array(
+ 'var' => 'userName',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
if (isset($vals['gatewayId'])) {
$this->gatewayId = $vals['gatewayId'];
}
+ if (isset($vals['userName'])) {
+ $this->userName = $vals['userName'];
+ }
}
}
public function getName() {
- return 'Airavata_deleteGateway_args';
+ return 'Airavata_generateAndRegisterSSHKeys_args';
}
public function read($input)
@@ -7797,6 +8625,13 @@ class Airavata_deleteGateway_args {
$xfer += $input->skip($ftype);
}
break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->userName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -7809,12 +8644,17 @@ class Airavata_deleteGateway_args {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_deleteGateway_args');
+ $xfer += $output->writeStructBegin('Airavata_generateAndRegisterSSHKeys_args');
if ($this->gatewayId !== null) {
$xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 1);
$xfer += $output->writeString($this->gatewayId);
$xfer += $output->writeFieldEnd();
}
+ if ($this->userName !== null) {
+ $xfer += $output->writeFieldBegin('userName', TType::STRING, 2);
+ $xfer += $output->writeString($this->userName);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -7822,7 +8662,7 @@ class Airavata_deleteGateway_args {
}
-class Airavata_deleteGateway_result {
+class Airavata_generateAndRegisterSSHKeys_result {
static $_TSPEC;
public $success = null;
@@ -7835,7 +8675,7 @@ class Airavata_deleteGateway_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::BOOL,
+ 'type' => TType::STRING,
),
1 => array(
'var' => 'ire',
@@ -7871,7 +8711,7 @@ class Airavata_deleteGateway_result {
}
public function getName() {
- return 'Airavata_deleteGateway_result';
+ return 'Airavata_generateAndRegisterSSHKeys_result';
}
public function read($input)
@@ -7890,8 +8730,8 @@ class Airavata_deleteGateway_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->success);
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -7932,10 +8772,10 @@ class Airavata_deleteGateway_result {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_deleteGateway_result');
+ $xfer += $output->writeStructBegin('Airavata_generateAndRegisterSSHKeys_result');
if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
- $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -7960,19 +8800,29 @@ class Airavata_deleteGateway_result {
}
-class Airavata_getAllGateways_args {
+class Airavata_getSSHPubKey_args {
static $_TSPEC;
+ public $airavataCredStoreToken = null;
- public function __construct() {
+ public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'airavataCredStoreToken',
+ 'type' => TType::STRING,
+ ),
);
}
+ if (is_array($vals)) {
+ if (isset($vals['airavataCredStoreToken'])) {
+ $this->airavataCredStoreToken = $vals['airavataCredStoreToken'];
+ }
+ }
}
public function getName() {
- return 'Airavata_getAllGateways_args';
+ return 'Airavata_getSSHPubKey_args';
}
public function read($input)
@@ -7990,6 +8840,13 @@ class Airavata_getAllGateways_args {
}
switch ($fid)
{
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->airavataCredStoreToken);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -8002,7 +8859,12 @@ class Airavata_getAllGateways_args {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_getAllGateways_args');
+ $xfer += $output->writeStructBegin('Airavata_getSSHPubKey_args');
+ if ($this->airavataCredStoreToken !== null) {
+ $xfer += $output->writeFieldBegin('airavataCredStoreToken', TType::STRING, 1);
+ $xfer += $output->writeString($this->airavataCredStoreToken);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -8010,7 +8872,7 @@ class Airavata_getAllGateways_args {
}
-class Airavata_getAllGateways_result {
+class Airavata_getSSHPubKey_result {
static $_TSPEC;
public $success = null;
@@ -8023,12 +8885,7 @@ class Airavata_getAllGateways_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::LST,
- 'etype' => TType::STRUCT,
- 'elem' => array(
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\Workspace\Gateway',
- ),
+ 'type' => TType::STRING,
),
1 => array(
'var' => 'ire',
@@ -8064,7 +8921,7 @@ class Airavata_getAllGateways_result {
}
public function getName() {
- return 'Airavata_getAllGateways_result';
+ return 'Airavata_getSSHPubKey_result';
}
public function read($input)
@@ -8083,19 +8940,8 @@ class Airavata_getAllGateways_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::LST) {
- $this->success = array();
- $_size0 = 0;
- $_etype3 = 0;
- $xfer += $input->readListBegin($_etype3, $_size0);
- for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
- {
- $elem5 = null;
- $elem5 = new \Airavata\Model\Workspace\Gateway();
- $xfer += $elem5->read($input);
- $this->success []= $elem5;
- }
- $xfer += $input->readListEnd();
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -8136,22 +8982,10 @@ class Airavata_getAllGateways_result {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_getAllGateways_result');
+ $xfer += $output->writeStructBegin('Airavata_getSSHPubKey_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 $iter6)
- {
- $xfer += $iter6->write($output);
- }
- }
- $output->writeListEnd();
- }
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -8176,29 +9010,29 @@ class Airavata_getAllGateways_result {
}
-class Airavata_isGatewayExist_args {
+class Airavata_getAllUserSSHPubKeys_args {
static $_TSPEC;
- public $gatewayId = null;
+ public $userName = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
self::$_TSPEC = array(
1 => array(
- 'var' => 'gatewayId',
+ 'var' => 'userName',
'type' => TType::STRING,
),
);
}
if (is_array($vals)) {
- if (isset($vals['gatewayId'])) {
- $this->gatewayId = $vals['gatewayId'];
+ if (isset($vals['userName'])) {
+ $this->userName = $vals['userName'];
}
}
}
public function getName() {
- return 'Airavata_isGatewayExist_args';
+ return 'Airavata_getAllUserSSHPubKeys_args';
}
public function read($input)
@@ -8218,7 +9052,7 @@ class Airavata_isGatewayExist_args {
{
case 1:
if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->gatewayId);
+ $xfer += $input->readString($this->userName);
} else {
$xfer += $input->skip($ftype);
}
@@ -8235,10 +9069,10 @@ class Airavata_isGatewayExist_args {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_isGatewayExist_args');
- if ($this->gatewayId !== null) {
- $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 1);
- $xfer += $output->writeString($this->gatewayId);
+ $xfer += $output->writeStructBegin('Airavata_getAllUserSSHPubKeys_args');
+ if ($this->userName !== null) {
+ $xfer += $output->writeFieldBegin('userName', TType::STRING, 1);
+ $xfer += $output->writeString($this->userName);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
@@ -8248,7 +9082,7 @@ class Airavata_isGatewayExist_args {
}
-class Airavata_isGatewayExist_result {
+class Airavata_getAllUserSSHPubKeys_result {
static $_TSPEC;
public $success = null;
@@ -8261,7 +9095,15 @@ class Airavata_isGatewayExist_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::BOOL,
+ 'type' => TType::MAP,
+ 'ktype' => TType::STRING,
+ 'vtype' => TType::STRING,
+ 'key' => array(
+ 'type' => TType::STRING,
+ ),
+ 'val' => array(
+ 'type' => TType::STRING,
+ ),
),
1 => array(
'var' => 'ire',
@@ -8297,7 +9139,7 @@ class Airavata_isGatewayExist_result {
}
public function getName() {
- return 'Airavata_isGatewayExist_result';
+ return 'Airavata_getAllUserSSHPubKeys_result';
}
public function read($input)
@@ -8316,8 +9158,21 @@ class Airavata_isGatewayExist_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->success);
+ if ($ftype == TType::MAP) {
+ $this->success = array();
+ $_size7 = 0;
+ $_ktype8 = 0;
+ $_vtype9 = 0;
+ $xfer += $input->readMapBegin($_ktype8, $_vtype9, $_size7);
+ for ($_i11 = 0; $_i11 < $_size7; ++$_i11)
+ {
+ $key12 = '';
+ $val13 = '';
+ $xfer += $input->readString($key12);
+ $xfer += $input->readString($val13);
+ $this->success[$key12] = $val13;
+ }
+ $xfer += $input->readMapEnd();
} else {
$xfer += $input->skip($ftype);
}
@@ -8358,10 +9213,23 @@ class Airavata_isGatewayExist_result {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_isGatewayExist_result');
+ $xfer += $output->writeStructBegin('Airavata_getAllUserSSHPubKeys_result');
if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
- $xfer += $output->writeBool($this->success);
+ if (!is_array($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::MAP, 0);
+ {
+ $output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
+ {
+ foreach ($this->success as $kiter14 => $viter15)
+ {
+ $xfer += $output->writeString($kiter14);
+ $xfer += $output->writeString($viter15);
+ }
+ }
+ $output->writeMapEnd();
+ }
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -9222,15 +10090,15 @@ class Airavata_getAllUserProjects_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size7 = 0;
- $_etype10 = 0;
- $xfer += $input->readListBegin($_etype10, $_size7);
- for ($_i11 = 0; $_i11 < $_size7; ++$_i11)
+ $_size16 = 0;
+ $_etype19 = 0;
+ $xfer += $input->readListBegin($_etype19, $_size16);
+ for ($_i20 = 0; $_i20 < $_size16; ++$_i20)
{
- $elem12 = null;
- $elem12 = new \Airavata\Model\Workspace\Project();
- $xfer += $elem12->read($input);
- $this->success []= $elem12;
+ $elem21 = null;
+ $elem21 = new \Airavata\Model\Workspace\Project();
+ $xfer += $elem21->read($input);
+ $this->success []= $elem21;
}
$xfer += $input->readListEnd();
} else {
@@ -9282,9 +10150,9 @@ class Airavata_getAllUserProjects_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter13)
+ foreach ($this->success as $iter22)
{
- $xfer += $iter13->write($output);
+ $xfer += $iter22->write($output);
}
}
$output->writeListEnd();
@@ -9480,15 +10348,15 @@ class Airavata_searchProjectsByProjectName_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size14 = 0;
- $_etype17 = 0;
- $xfer += $input->readListBegin($_etype17, $_size14);
- for ($_i18 = 0; $_i18 < $_size14; ++$_i18)
+ $_size23 = 0;
+ $_etype26 = 0;
+ $xfer += $input->readListBegin($_etype26, $_size23);
+ for ($_i27 = 0; $_i27 < $_size23; ++$_i27)
{
- $elem19 = null;
- $elem19 = new \Airavata\Model\Workspace\Project();
- $xfer += $elem19->read($input);
- $this->success []= $elem19;
+ $elem28 = null;
+ $elem28 = new \Airavata\Model\Workspace\Project();
+ $xfer += $elem28->read($input);
+ $this->success []= $elem28;
}
$xfer += $input->readListEnd();
} else {
@@ -9540,9 +10408,9 @@ class Airavata_searchProjectsByProjectName_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter20)
+ foreach ($this->success as $iter29)
{
- $xfer += $iter20->write($output);
+ $xfer += $iter29->write($output);
}
}
$output->writeListEnd();
@@ -9738,15 +10606,15 @@ class Airavata_searchProjectsByProjectDesc_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size21 = 0;
- $_etype24 = 0;
- $xfer += $input->readListBegin($_etype24, $_size21);
- for ($_i25 = 0; $_i25 < $_size21; ++$_i25)
+ $_size30 = 0;
+ $_etype33 = 0;
+ $xfer += $input->readListBegin($_etype33, $_size30);
+ for ($_i34 = 0; $_i34 < $_size30; ++$_i34)
{
- $elem26 = null;
- $elem26 = new \Airavata\Model\Workspace\Project();
- $xfer += $elem26->read($input);
- $this->success []= $elem26;
+ $elem35 = null;
+ $elem35 = new \Airavata\Model\Workspace\Project();
+ $xfer += $elem35->read($input);
+ $this->success []= $elem35;
}
$xfer += $input->readListEnd();
} else {
@@ -9798,9 +10666,9 @@ class Airavata_searchProjectsByProjectDesc_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter27)
+ foreach ($this->success as $iter36)
{
- $xfer += $iter27->write($output);
+ $xfer += $iter36->write($output);
}
}
$output->writeListEnd();
@@ -9996,15 +10864,15 @@ class Airavata_searchExperimentsByName_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size28 = 0;
- $_etype31 = 0;
- $xfer += $input->readListBegin($_etype31, $_size28);
- for ($_i32 = 0; $_i32 < $_size28; ++$_i32)
+ $_size37 = 0;
+ $_etype40 = 0;
+ $xfer += $input->readListBegin($_etype40, $_size37);
+ for ($_i41 = 0; $_i41 < $_size37; ++$_i41)
{
- $elem33 = null;
- $elem33 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
- $xfer += $elem33->read($input);
- $this->success []= $elem33;
+ $elem42 = null;
+ $elem42 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
+ $xfer += $elem42->read($input);
+ $this->success []= $elem42;
}
$xfer += $input->readListEnd();
} else {
@@ -10056,9 +10924,9 @@ class Airavata_searchExperimentsByName_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter34)
+ foreach ($this->success as $iter43)
{
- $xfer += $iter34->write($output);
+ $xfer += $iter43->write($output);
}
}
$output->writeListEnd();
@@ -10254,15 +11122,15 @@ class Airavata_searchExperimentsByDesc_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size35 = 0;
- $_etype38 = 0;
- $xfer += $input->readListBegin($_etype38, $_size35);
- for ($_i39 = 0; $_i39 < $_size35; ++$_i39)
+ $_size44 = 0;
+ $_etype47 = 0;
+ $xfer += $input->readListBegin($_etype47, $_size44);
+ for ($_i48 = 0; $_i48 < $_size44; ++$_i48)
{
- $elem40 = null;
- $elem40 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
- $xfer += $elem40->read($input);
- $this->success []= $elem40;
+ $elem49 = null;
+ $elem49 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
+ $xfer += $elem49->read($input);
+ $this->success []= $elem49;
}
$xfer += $input->readListEnd();
} else {
@@ -10314,9 +11182,9 @@ class Airavata_searchExperimentsByDesc_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter41)
+ foreach ($this->success as $iter50)
{
- $xfer += $iter41->write($output);
+ $xfer += $iter50->write($output);
}
}
$output->writeListEnd();
@@ -10512,15 +11380,15 @@ class Airavata_searchExperimentsByApplication_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size42 = 0;
- $_etype45 = 0;
- $xfer += $input->readListBegin($_etype45, $_size42);
- for ($_i46 = 0; $_i46 < $_size42; ++$_i46)
+ $_size51 = 0;
+ $_etype54 = 0;
+ $xfer += $input->readListBegin($_etype54, $_size51);
+ for ($_i55 = 0; $_i55 < $_size51; ++$_i55)
{
- $elem47 = null;
- $elem47 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
- $xfer += $elem47->read($input);
- $this->success []= $elem47;
+ $elem56 = null;
+ $elem56 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
+ $xfer += $elem56->read($input);
+ $this->success []= $elem56;
}
$xfer += $input->readListEnd();
} else {
@@ -10572,9 +11440,9 @@ class Airavata_searchExperimentsByApplication_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter48)
+ foreach ($this->success as $iter57)
{
- $xfer += $iter48->write($output);
+ $xfer += $iter57->write($output);
}
}
$output->writeListEnd();
@@ -10770,15 +11638,15 @@ class Airavata_searchExperimentsByStatus_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size49 = 0;
- $_etype52 = 0;
- $xfer += $input->readListBegin($_etype52, $_size49);
- for ($_i53 = 0; $_i53 < $_size49; ++$_i53)
+ $_size58 = 0;
+ $_etype61 = 0;
+ $xfer += $input->readListBegin($_etype61, $_size58);
+ for ($_i62 = 0; $_i62 < $_size58; ++$_i62)
{
- $elem54 = null;
- $elem54 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
- $xfer += $elem54->read($input);
- $this->success []= $elem54;
+ $elem63 = null;
+ $elem63 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
+ $xfer += $elem63->read($input);
+ $this->success []= $elem63;
}
$xfer += $input->readListEnd();
} else {
@@ -10830,9 +11698,9 @@ class Airavata_searchExperimentsByStatus_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter55)
+ foreach ($this->success as $iter64)
{
- $xfer += $iter55->write($output);
+ $xfer += $iter64->write($output);
}
}
$output->writeListEnd();
@@ -11048,15 +11916,15 @@ class Airavata_searchExperimentsByCreationTime_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size56 = 0;
- $_etype59 = 0;
- $xfer += $input->readListBegin($_etype59, $_size56);
- for ($_i60 = 0; $_i60 < $_size56; ++$_i60)
+ $_size65 = 0;
+ $_etype68 = 0;
+ $xfer += $input->readListBegin($_etype68, $_size65);
+ for ($_i69 = 0; $_i69 < $_size65; ++$_i69)
{
- $elem61 = null;
- $elem61 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
- $xfer += $elem61->read($input);
- $this->success []= $elem61;
+ $elem70 = null;
+ $elem70 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
+ $xfer += $elem70->read($input);
+ $this->success []= $elem70;
}
$xfer += $input->readListEnd();
} else {
@@ -11108,9 +11976,9 @@ class Airavata_searchExperimentsByCreationTime_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter62)
+ foreach ($this->success as $iter71)
{
- $xfer += $iter62->write($output);
+ $xfer += $iter71->write($output);
}
}
$output->writeListEnd();
@@ -11295,15 +12163,15 @@ class Airavata_getAllExperimentsInProject_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size63 = 0;
- $_etype66 = 0;
- $xfer += $input->readListBegin($_etype66, $_size63);
- for ($_i67 = 0; $_i67 < $_size63; ++$_i67)
+ $_size72 = 0;
+ $_etype75 = 0;
+ $xfer += $input->readListBegin($_etype75, $_size72);
+ for ($_i76 = 0; $_i76 < $_size72; ++$_i76)
{
- $elem68 = null;
- $elem68 = new \Airavata\Model\Workspace\Experiment\Experiment();
- $xfer += $elem68->read($input);
- $this->success []= $elem68;
+ $elem77 = null;
+ $elem77 = new \Airavata\Model\Workspace\Experiment\Experiment();
+ $xfer += $elem77->read($input);
+ $this->success []= $elem77;
}
$xfer += $input->readListEnd();
} else {
@@ -11363,9 +12231,9 @@ class Airavata_getAllExperimentsInProject_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter69)
+ foreach ($this->success as $iter78)
{
- $xfer += $iter69->write($output);
+ $xfer += $iter78->write($output);
}
}
$output->writeListEnd();
@@ -11546,15 +12414,15 @@ class Airavata_getAllUserExperiments_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size70 = 0;
- $_etype73 = 0;
- $xfer += $input->readListBegin($_etype73, $_size70);
- for ($_i74 = 0; $_i74 < $_size70; ++$_i74)
+ $_size79 = 0;
+ $_etype82 = 0;
+ $xfer += $input->readListBegin($_etype82, $_size79);
+ for ($_i83 = 0; $_i83 < $_size79; ++$_i83)
{
- $elem75 = null;
- $elem75 = new \Airavata\Model\Workspace\Experiment\Experiment();
- $xfer += $elem75->read($input);
- $this->success []= $elem75;
+ $elem84 = null;
+ $elem84 = new \Airavata\Model\Workspace\Experiment\Experiment();
+ $xfer += $elem84->read($input);
+ $this->success []= $elem84;
}
$xfer += $input->readListEnd();
} else {
@@ -11606,9 +12474,9 @@ class Airavata_getAllUserExperiments_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter76)
+ foreach ($this->success as $iter85)
{
- $xfer += $iter76->write($output);
+ $xfer += $iter85->write($output);
}
}
$output->writeListEnd();
@@ -13499,15 +14367,15 @@ class Airavata_getExperimentOutputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size77 = 0;
- $_etype80 = 0;
- $xfer += $input->readListBegin($_etype80, $_size77);
- for ($_i81 = 0; $_i81 < $_size77; ++$_i81)
+ $_size86 = 0;
+ $_etype89 = 0;
+ $xfer += $input->readListBegin($_etype89, $_size86);
+ for ($_i90 = 0; $_i90 < $_size86; ++$_i90)
{
- $elem82 = null;
- $elem82 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
- $xfer += $elem82->read($input);
- $this->success []= $elem82;
+ $elem91 = null;
+ $elem91 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
+ $xfer += $elem91->read($input);
+ $this->success []= $elem91;
}
$xfer += $input->readListEnd();
} else {
@@ -13567,9 +14435,9 @@ class Airavata_getExperimentOutputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter83)
+ foreach ($this->success as $iter92)
{
- $xfer += $iter83->write($output);
+ $xfer += $iter92->write($output);
}
}
$output->writeListEnd();
@@ -13759,15 +14627,15 @@ class Airavata_getIntermediateOutputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size84 = 0;
- $_etype87 = 0;
- $xfer += $input->readListBegin($_etype87, $_size84);
- for ($_i88 = 0; $_i88 < $_size84; ++$_i88)
+ $_size93 = 0;
+ $_etype96 = 0;
+ $xfer += $input->readListBegin($_etype96, $_size93);
+ for ($_i97 = 0; $_i97 < $_size93; ++$_i97)
{
- $elem89 = null;
- $elem89 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
- $xfer += $elem89->read($input);
- $this->success []= $elem89;
+ $elem98 = null;
+ $elem98 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
+ $xfer += $elem98->read($input);
+ $this->success []= $elem98;
}
$xfer += $input->readListEnd();
} else {
@@ -13827,9 +14695,9 @@ class Airavata_getIntermediateOutputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter90)
+ foreach ($this->success as $iter99)
{
- $xfer += $iter90->write($output);
+ $xfer += $iter99->write($output);
}
}
$output->writeListEnd();
@@ -14023,18 +14891,18 @@ class Airavata_getJobStatuses_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size91 = 0;
- $_ktype92 = 0;
- $_vtype93 = 0;
- $xfer += $input->readMapBegin($_ktype92, $_vtype93, $_size91);
- for ($_i95 = 0; $_i95 < $_size91; ++$_i95)
+ $_size100 = 0;
+ $_ktype101 = 0;
+ $_vtype102 = 0;
+ $xfer += $input->readMapBegin($_ktype101, $_vtype102, $_size100);
+ for ($_i104 = 0; $_i104 < $_size100; ++$_i104)
{
- $key96 = '';
- $val97 = new \Airavata\Model\Workspace\Experiment\JobStatus();
- $xfer += $input->readString($key96);
- $val97 = new \Airavata\Model\Workspace\Experiment\JobStatus();
- $xfer += $val97->read($input);
- $this->success[$key96] = $val97;
+ $key105 = '';
+ $val106 = new \Airavata\Model\Workspace\Experiment\JobStatus();
+ $xfer += $input->readString($key105);
+ $val106 = new \Airavata\Model\Workspace\Experiment\JobStatus();
+ $xfer += $val106->read($input);
+ $this->success[$key105] = $val106;
}
$xfer += $input->readMapEnd();
} else {
@@ -14094,10 +14962,10 @@ class Airavata_getJobStatuses_result {
{
$output->writeMapBegin(TType::STRING, TType::STRUCT, count($this->success));
{
- foreach ($this->success as $kiter98 => $viter99)
+ foreach ($this->success as $kiter107 => $viter108)
{
- $xfer += $output->writeString($kiter98);
- $xfer += $viter99->write($output);
+ $xfer += $output->writeString($kiter107);
+ $xfer += $viter108->write($output);
}
}
$output->writeMapEnd();
@@ -14287,15 +15155,15 @@ class Airavata_getJobDetails_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size100 = 0;
- $_etype103 = 0;
- $xfer += $input->readListBegin($_etype103, $_size100);
- for ($_i104 = 0; $_i104 < $_size100; ++$_i104)
+ $_size109 = 0;
+ $_etype112 = 0;
+ $xfer += $input->readListBegin($_etype112, $_size109);
+ for ($_i113 = 0; $_i113 < $_size109; ++$_i113)
{
- $elem105 = null;
- $elem105 = new \Airavata\Model\Workspace\Experiment\JobDetails();
- $xfer += $elem105->read($input);
- $this->success []= $elem105;
+ $elem114 = null;
+ $elem114 = new \Airavata\Model\Workspace\Experiment\JobDetails();
+ $xfer += $elem114->read($input);
+ $this->success []= $elem114;
}
$xfer += $input->readListEnd();
} else {
@@ -14355,9 +15223,9 @@ class Airavata_getJobDetails_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter106)
+ foreach ($this->success as $iter115)
{
- $xfer += $iter106->write($output);
+ $xfer += $iter115->write($output);
}
}
$output->writeListEnd();
@@ -14547,15 +15415,15 @@ class Airavata_getDataTransferDetails_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size107 = 0;
- $_etype110 = 0;
- $xfer += $input->readListBegin($_etype110, $_size107);
- for ($_i111 = 0; $_i111 < $_size107; ++$_i111)
+ $_size116 = 0;
+ $_etype119 = 0;
+ $xfer += $input->readListBegin($_etype119, $_size116);
+ for ($_i120 = 0; $_i120 < $_size116; ++$_i120)
{
- $elem112 = null;
- $elem112 = new \Airavata\Model\Workspace\Experiment\DataTransferDetails();
- $xfer += $elem112->read($input);
- $this->success []= $elem112;
+ $elem121 = null;
+ $elem121 = new \Airavata\Model\Workspace\Experiment\DataTransferDetails();
+ $xfer += $elem121->read($input);
+ $this->success []= $elem121;
}
$xfer += $input->readListEnd();
} else {
@@ -14615,9 +15483,9 @@ class Airavata_getDataTransferDetails_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter113)
+ foreach ($this->success as $iter122)
{
- $xfer += $iter113->write($output);
+ $xfer += $iter122->write($output);
}
}
$output->writeListEnd();
@@ -15905,15 +16773,15 @@ class Airavata_getAllAppModules_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size114 = 0;
- $_etype117 = 0;
- $xfer += $input->readListBegin($_etype117, $_size114);
- for ($_i118 = 0; $_i118 < $_size114; ++$_i118)
+ $_size123 = 0;
+ $_etype126 = 0;
+ $xfer += $input->readListBegin($_etype126, $_size123);
+ for ($_i127 = 0; $_i127 < $_size123; ++$_i127)
{
- $elem119 = null;
- $elem119 = new \Airavata\Model\AppCatalog\AppDeployment\ApplicationModule();
- $xfer += $elem119->read($input);
- $this->success []= $elem119;
+ $elem128 = null;
+ $elem128 = new \Airavata\Model\AppCatalog\AppDeployment\ApplicationModule();
+ $xfer += $elem128->read($input);
+ $this->success []= $elem128;
}
$xfer += $input->readListEnd();
} else {
@@ -15965,9 +16833,9 @@ class Airavata_getAllAppModules_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter120)
+ foreach ($this->success as $iter129)
{
- $xfer += $iter120->write($output);
+ $xfer += $iter129->write($output);
}
}
$output->writeListEnd();
@@ -17206,15 +18074,15 @@ class Airavata_getAllApplicationDeployments_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size121 = 0;
- $_etype124 = 0;
- $xfer += $input->readListBegin($_etype124, $_size121);
- for ($_i125 = 0; $_i125 < $_size121; ++$_i125)
+ $_size130 = 0;
+ $_etype133 = 0;
+ $xfer += $input->readListBegin($_etype133, $_size130);
+ for ($_i134 = 0; $_i134 < $_size130; ++$_i134)
{
- $elem126 = null;
- $elem126 = new \Airavata\Model\AppCatalog\AppDeployment\ApplicationDeploymentDescription();
- $xfer += $elem126->read($input);
- $this->success []= $elem126;
+ $elem135 = null;
+ $elem135 = new \Airavata\Model\AppCatalog\AppDeployment\ApplicationDeploymentDescription();
+ $xfer += $elem135->read($input);
+ $this->success []= $elem135;
}
$xfer += $input->readListEnd();
} else {
@@ -17266,9 +18134,9 @@ class Airavata_getAllApplicationDeployments_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter127)
+ foreach ($this->success as $iter136)
{
- $xfer += $iter127->write($output);
+ $xfer += $iter136->write($output);
}
}
$output->writeListEnd();
@@ -17443,14 +18311,14 @@ class Airavata_getAppModuleDeployedResources_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size128 = 0;
- $_etype131 = 0;
- $xfer += $input->readListBegin($_etype131, $_size128);
- for ($_i132 = 0; $_i132 < $_size128; ++$_i132)
+ $_size137 = 0;
+ $_etype140 = 0;
+ $xfer += $input->readListBegin($_etype140, $_size137);
+ for ($_i141 = 0; $_i141 < $_size137; ++$_i141)
{
- $elem133 = null;
- $xfer += $input->readString($elem133);
- $this->success []= $elem133;
+ $elem142 = null;
+ $xfer += $input->readString($elem142);
+ $this->success []= $elem142;
}
$xfer += $input->readListEnd();
} else {
@@ -17502,9 +18370,9 @@ class Airavata_getAppModuleDeployedResources_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter134)
+ foreach ($this->success as $iter143)
{
- $xfer += $output->writeString($iter134);
+ $xfer += $output->writeString($iter143);
}
}
$output->writeListEnd();
@@ -18536,17 +19404,17 @@ class Airavata_getAllApplicationInterfaceNames_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size135 = 0;
- $_ktype136 = 0;
- $_vtype137 = 0;
- $xfer += $input->readMapBegin($_ktype136, $_vtype137, $_size135);
- for ($_i139 = 0; $_i139 < $_size135; ++$_i139)
+ $_size144 = 0;
+ $_ktype145 = 0;
+ $_vtype146 = 0;
+ $xfer += $input->readMapBegin($_ktype145, $_vtype146, $_size144);
+ for ($_i148 = 0; $_i148 < $_size144; ++$_i148)
{
- $key140 = '';
- $val141 = '';
- $xfer += $input->readString($key140);
- $xfer += $input->readString($val141);
- $this->success[$key140] = $val141;
+ $key149 = '';
+ $val150 = '';
+ $xfer += $input->readString($key149);
+ $xfer += $input->readString($val150);
+ $this->success[$key149] = $val150;
}
$xfer += $input->readMapEnd();
} else {
@@ -18598,10 +19466,10 @@ class Airavata_getAllApplicationInterfaceNames_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter142 => $viter143)
+ foreach ($this->success as $kiter151 => $viter152)
{
- $xfer += $output->writeString($kiter142);
- $xfer += $output->writeString($viter143);
+ $xfer += $output->writeString($kiter151);
+ $xfer += $output->writeString($viter152);
}
}
$output->writeMapEnd();
@@ -18755,15 +19623,15 @@ class Airavata_getAllApplicationInterfaces_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size144 = 0;
- $_etype147 = 0;
- $xfer += $input->readListBegin($_etype147, $_size144);
- for ($_i148 = 0; $_i148 < $_size144; ++$_i148)
+ $_size153 = 0;
+ $_etype156 = 0;
+ $xfer += $input->readListBegin($_etype156, $_size153);
+ for ($_i157 = 0; $_i157 < $_size153; ++$_i157)
{
- $elem149 = null;
- $elem149 = new \Airavata\Model\AppCatalog\AppInterface\ApplicationInterfaceDescription();
- $xfer += $elem149->read($input);
- $this->success []= $elem149;
+ $elem158 = null;
+ $elem158 = new \Airavata\Model\AppCatalog\AppInterface\ApplicationInterfaceDescription();
+ $xfer += $elem158->read($input);
+ $this->success []= $elem158;
}
$xfer += $input->readListEnd();
} else {
@@ -18815,9 +19683,9 @@ class Airavata_getAllApplicationInterfaces_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter150)
+ foreach ($this->success as $iter159)
{
- $xfer += $iter150->write($output);
+ $xfer += $iter159->write($output);
}
}
$output->writeListEnd();
@@ -18993,15 +19861,15 @@ class Airavata_getApplicationInputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size151 = 0;
- $_etype154 = 0;
- $xfer += $input->readListBegin($_etype154, $_size151);
- for ($_i155 = 0; $_i155 < $_size151; ++$_i155)
+ $_size160 = 0;
+ $_etype163 = 0;
+ $xfer += $input->readListBegin($_etype163, $_size160);
+ for ($_i164 = 0; $_i164 < $_size160; ++$_i164)
{
- $elem156 = null;
- $elem156 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType();
- $xfer += $elem156->read($input);
- $this->success []= $elem156;
+ $elem165 = null;
+ $elem165 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType();
+ $xfer += $elem165->read($input);
+ $this->success []= $elem165;
}
$xfer += $input->readListEnd();
} else {
@@ -19053,9 +19921,9 @@ class Airavata_getApplicationInputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter157)
+ foreach ($this->success as $iter166)
{
- $xfer += $iter157->write($output);
+ $xfer += $iter166->write($output);
}
}
$output->writeListEnd();
@@ -19231,15 +20099,15 @@ class Airavata_getApplicationOutputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size158 = 0;
- $_etype161 = 0;
- $xfer += $input->readListBegin($_etype161, $_size158);
- for ($_i162 = 0; $_i162 < $_size158; ++$_i162)
+ $_size167 = 0;
+ $_etype170 = 0;
+ $xfer += $input->readListBegin($_etype170, $_size167);
+ for ($_i171 = 0; $_i171 < $_size167; ++$_i171)
{
- $elem163 = null;
- $elem163 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
- $xfer += $elem163->read($input);
- $this->success []= $elem163;
+ $elem172 = null;
+ $elem172 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
+ $xfer += $elem172->read($input);
+ $this->success []= $elem172;
}
$xfer += $input->readListEnd();
} else {
@@ -19291,9 +20159,9 @@ class Airavata_getApplicationOutputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter164)
+ foreach ($this->success as $iter173)
{
- $xfer += $iter164->write($output);
+ $xfer += $iter173->write($output);
}
}
$output->writeListEnd();
@@ -19472,17 +20340,17 @@ class Airavata_getAvailableAppInterfaceComputeResources_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size165 = 0;
- $_ktype166 = 0;
- $_vtype167 = 0;
- $xfer += $input->readMapBegin($_ktype166, $_vtype167, $_size165);
- for ($_i169 = 0; $_i169 < $_size165; ++$_i169)
+ $_size174 = 0;
+ $_ktype175 = 0;
+ $_vtype176 = 0;
+ $xfer += $input->readMapBegin($_ktype175, $_vtype176, $_size174);
+ for ($_i178 = 0; $_i178 < $_size174; ++$_i178)
{
- $key170 = '';
- $val171 = '';
- $xfer += $input->readString($key170);
- $xfer += $input->readString($val171);
- $this->success[$key170] = $val171;
+ $key179 = '';
+ $val180 = '';
+ $xfer += $input->readString($key179);
+ $xfer += $input->readString($val180);
+ $this->success[$key179] = $val180;
}
$xfer += $input->readMapEnd();
} else {
@@ -19534,10 +20402,10 @@ class Airavata_getAvailableAppInterfaceComputeResources_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter172 => $viter173)
+ foreach ($this->success as $kiter181 => $viter182)
{
- $xfer += $output->writeString($kiter172);
- $xfer += $output->writeString($viter173);
+ $xfer += $output->writeString($kiter181);
+ $xfer += $output->writeString($viter182);
}
}
$output->writeMapEnd();
@@ -20124,17 +20992,17 @@ class Airavata_getAllComputeResourceNames_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size174 = 0;
- $_ktype175 = 0;
- $_vtype176 = 0;
- $xfer += $input->readMapBegin($_ktype175, $_vtype176, $_size174);
- for ($_i178 = 0; $_i178 < $_size174; ++$_i178)
+ $_size183 = 0;
+ $_ktype184 = 0;
+ $_vtype185 = 0;
+ $xfer += $input->readMapBegin($_ktype184, $_vtype185, $_size183);
+ for ($_i187 = 0; $_i187 < $_size183; ++$_i187)
{
- $key179 = '';
- $val180 = '';
- $xfer += $input->readString($key179);
- $xfer += $input->readString($val180);
- $this->success[$key179] = $val180;
+ $key188 = '';
+ $val189 = '';
+ $xfer += $input->readString($key188);
+ $xfer += $input->readString($val189);
+ $this->success[$key188] = $val189;
}
$xfer += $input->readMapEnd();
} else {
@@ -20186,10 +21054,10 @@ class Airavata_getAllComputeResourceNames_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter181 => $viter182)
+ foreach ($this->success as $kiter190 => $viter191)
{
- $xfer += $output->writeString($kiter181);
- $xfer += $output->writeString($viter182);
+ $xfer += $output->writeString($kiter190);
+ $xfer += $output->writeString($viter191);
}
}
$output->writeMapEnd();
@@ -26814,17 +27682,17 @@ class Airavata_changeJobSubmissionPriorities_args {
case 1:
if ($ftype == TType::MAP) {
$this->jobSubmissionPriorityMap = array();
- $_size183 = 0;
- $_ktype184 = 0;
- $_vtype185 = 0;
- $xfer += $input->readMapBegin($_ktype184, $_vtype185, $_size183);
- for ($_i187 = 0; $_i187 < $_size183; ++$_i187)
+ $_size192 = 0;
+ $_ktype193 = 0;
+ $_vtype194 = 0;
+ $xfer += $input->readMapBegin($_ktype193, $_vtype194, $_size192);
+ for ($_i196 = 0; $_i196 < $_size192; ++$_i196)
{
- $key188 = '';
- $val189 = 0;
- $xfer += $input->readString($key188);
- $xfer += $input->readI32($val189);
- $this->jobSubmissionPriorityMap[$key188] = $val189;
+ $key197 = '';
+ $val198 = 0;
+ $xfer += $input->readString($key197);
+ $xfer += $input->readI32($val198);
+ $this->jobSubmissionPriorityMap[$key197] = $val198;
}
$xfer += $input->readMapEnd();
} else {
@@ -26852,10 +27720,10 @@ class Airavata_changeJobSubmissionPriorities_args {
{
$output->writeMapBegin(TType::STRING, TType::I32, count($this->jobSubmissionPriorityMap));
{
- foreach ($this->jobSubmissionPriorityMap as $kiter190 => $viter191)
+ foreach ($this->jobSubmissionPriorityMap as $kiter199 => $viter200)
{
- $xfer += $output->writeString($kiter190);
- $xfer += $output->writeI32($viter191);
+ $xfer += $output->writeString($kiter199);
+ $xfer += $output->writeI32($viter200);
}
}
$output->writeMapEnd();
@@ -27058,17 +27926,17 @@ class Airavata_changeDataMovementPriorities_args {
case 1:
if ($ftype == TType::MAP) {
$this->dataMovementPriorityMap = array();
- $_size192 = 0;
- $_ktype193 = 0;
- $_vtype194 = 0;
- $xfer += $input->readMapBegin($_ktype193, $_vtype194, $_size192);
- for ($_i196 = 0; $_i196 < $_size192; ++$_i196)
+ $_size201 = 0;
+ $_ktype202 = 0;
+ $_vtype203 = 0;
+ $xfer += $input->readMapBegin($_ktype202, $_vtype203, $_size201);
+ for ($_i205 = 0; $_i205 < $_size201; ++$_i205)
{
- $key197 = '';
- $val198 = 0;
- $xfer += $input->readString($key197);
- $xfer += $input->readI32($val198);
- $this->dataMovementPriorityMap[$key197] = $val198;
+ $key206 = '';
+ $val207 = 0;
+ $xfer += $input->readString($key206);
+ $xfer += $input->readI32($val207);
+ $this->dataMovementPriorityMap[$key206] = $val207;
}
$xfer += $input->readMapEnd();
} else {
@@ -27096,10 +27964,10 @@ class Airavata_changeDataMovementPriorities_args {
{
$output->writeMapBegin(TType::STRING, TType::I32, count($this->dataMovementPriorityMap));
{
- foreach ($this->dataMovementPriorityMap as $kiter199 => $viter200)
+ foreach ($this->dataMovementPriorityMap as $kiter208 => $viter209)
{
- $xfer += $output->writeString($kiter199);
- $xfer += $output->writeI32($viter200);
+ $xfer += $output->writeString($kiter208);
+ $xfer += $output->writeI32($viter209);
}
}
$output->writeMapEnd();
@@ -30328,15 +31196,15 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size201 = 0;
- $_etype204 = 0;
- $xfer += $input->readListBegin($_etype204, $_size201);
- for ($_i205 = 0; $_i205 < $_size201; ++$_i205)
+ $_size210 = 0;
+ $_etype213 = 0;
+ $xfer += $input->readListBegin($_etype213, $_size210);
+ for ($_i214 = 0; $_i214 < $_size210; ++$_i214)
{
- $elem206 = null;
- $elem206 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
- $xfer += $elem206->read($input);
- $this->success []= $elem206;
+ $elem215 = null;
+ $elem215 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
+ $xfer += $elem215->read($input);
+ $this->success []= $elem215;
}
$xfer += $input->readListEnd();
} else {
@@ -30388,9 +31256,9 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter207)
+ foreach ($this->success as $iter216)
{
- $xfer += $iter207->write($output);
+ $xfer += $iter216->write($output);
}
}
$output->writeListEnd();
@@ -30544,15 +31412,15 @@ class Airavata_getAllGatewayComputeResources_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size208 = 0;
- $_etype211 = 0;
- $xfer += $input->readListBegin($_etype211, $_size208);
- for ($_i212 = 0; $_i212 < $_size208; ++$_i212)
+ $_size217 = 0;
+ $_etype220 = 0;
+ $xfer += $input->readListBegin($_etype220, $_size217);
+ for ($_i221 = 0; $_i221 < $_size217; ++$_i221)
{
- $elem213 = null;
- $elem213 = new \Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile();
- $xfer += $elem213->read($input);
- $this->success []= $elem213;
+ $elem222 = null;
+ $elem222 = new \Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile();
+ $xfer += $elem222->read($input);
+ $this->success []= $elem222;
}
$xfer += $input->readListEnd();
} else {
@@ -30604,9 +31472,9 @@ class Airavata_getAllGatewayComputeResources_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter214)
+ foreach ($this->success as $iter223)
{
- $xfer += $iter214->write($output);
+ $xfer += $iter223->write($output);
}
}
$output->writeListEnd();
@@ -31244,14 +32112,14 @@ class Airavata_getAllWorkflows_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size215 = 0;
- $_etype218 = 0;
- $xfer += $input->readListBegin($_etype218, $_size215);
- for ($_i219 = 0; $_i219 < $_size215; ++$_i219)
+ $_size224 = 0;
+ $_etype227 = 0;
+ $xfer += $input->readListBegin($_etype227, $_size224);
+ for ($_i228 = 0; $_i228 < $_size224; ++$_i228)
{
- $elem220 = null;
- $xfer += $input->readString($elem220);
- $this->success []= $elem220;
+ $elem229 = null;
+ $xfer += $input->readString($elem229);
+ $this->success []= $elem229;
}
$xfer += $input->readListEnd();
} else {
@@ -31303,9 +32171,9 @@ class Airavata_getAllWorkflows_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter221)
+ foreach ($this->success as $iter230)
{
- $xfer += $output->writeString($iter221);
+ $xfer += $output->writeString($iter230);
}
}
$output->writeListEnd();
[4/5] airavata git commit: Stubs for credential store api methods -
AIRAVATA-1616
Posted by sm...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/33b403fc/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
index 15015ba..d1dc67c 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
@@ -1583,7 +1583,7 @@ uint32_t Airavata_isGatewayExist_presult::read(::apache::thrift::protocol::TProt
return xfer;
}
-uint32_t Airavata_createProject_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_generateAndRegisterSSHKeys_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -1594,7 +1594,8 @@ uint32_t Airavata_createProject_args::read(::apache::thrift::protocol::TProtocol
using ::apache::thrift::protocol::TProtocolException;
- bool isset_project = false;
+ bool isset_gatewayId = false;
+ bool isset_userName = false;
while (true)
{
@@ -1605,9 +1606,17 @@ uint32_t Airavata_createProject_args::read(::apache::thrift::protocol::TProtocol
switch (fid)
{
case 1:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->project.read(iprot);
- isset_project = true;
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->gatewayId);
+ isset_gatewayId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->userName);
+ isset_userName = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -1621,17 +1630,23 @@ uint32_t Airavata_createProject_args::read(::apache::thrift::protocol::TProtocol
xfer += iprot->readStructEnd();
- if (!isset_project)
+ if (!isset_gatewayId)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_userName)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_createProject_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_generateAndRegisterSSHKeys_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_createProject_args");
+ xfer += oprot->writeStructBegin("Airavata_generateAndRegisterSSHKeys_args");
- xfer += oprot->writeFieldBegin("project", ::apache::thrift::protocol::T_STRUCT, 1);
- xfer += this->project.write(oprot);
+ xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->gatewayId);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->userName);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -1639,12 +1654,16 @@ uint32_t Airavata_createProject_args::write(::apache::thrift::protocol::TProtoco
return xfer;
}
-uint32_t Airavata_createProject_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_generateAndRegisterSSHKeys_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_createProject_pargs");
+ xfer += oprot->writeStructBegin("Airavata_generateAndRegisterSSHKeys_pargs");
- xfer += oprot->writeFieldBegin("project", ::apache::thrift::protocol::T_STRUCT, 1);
- xfer += (*(this->project)).write(oprot);
+ xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->gatewayId)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->userName)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -1652,7 +1671,7 @@ uint32_t Airavata_createProject_pargs::write(::apache::thrift::protocol::TProtoc
return xfer;
}
-uint32_t Airavata_createProject_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_generateAndRegisterSSHKeys_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -1716,11 +1735,11 @@ uint32_t Airavata_createProject_result::read(::apache::thrift::protocol::TProtoc
return xfer;
}
-uint32_t Airavata_createProject_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_generateAndRegisterSSHKeys_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_createProject_result");
+ xfer += oprot->writeStructBegin("Airavata_generateAndRegisterSSHKeys_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
@@ -1744,7 +1763,7 @@ uint32_t Airavata_createProject_result::write(::apache::thrift::protocol::TProto
return xfer;
}
-uint32_t Airavata_createProject_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_generateAndRegisterSSHKeys_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -1808,7 +1827,7 @@ uint32_t Airavata_createProject_presult::read(::apache::thrift::protocol::TProto
return xfer;
}
-uint32_t Airavata_updateProject_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getSSHPubKey_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -1819,8 +1838,7 @@ uint32_t Airavata_updateProject_args::read(::apache::thrift::protocol::TProtocol
using ::apache::thrift::protocol::TProtocolException;
- bool isset_projectId = false;
- bool isset_updatedProject = false;
+ bool isset_airavataCredStoreToken = false;
while (true)
{
@@ -1832,16 +1850,8 @@ uint32_t Airavata_updateProject_args::read(::apache::thrift::protocol::TProtocol
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->projectId);
- isset_projectId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->updatedProject.read(iprot);
- isset_updatedProject = true;
+ xfer += iprot->readString(this->airavataCredStoreToken);
+ isset_airavataCredStoreToken = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -1855,23 +1865,17 @@ uint32_t Airavata_updateProject_args::read(::apache::thrift::protocol::TProtocol
xfer += iprot->readStructEnd();
- if (!isset_projectId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_updatedProject)
+ if (!isset_airavataCredStoreToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_updateProject_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getSSHPubKey_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_updateProject_args");
-
- xfer += oprot->writeFieldBegin("projectId", ::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->projectId);
- xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeStructBegin("Airavata_getSSHPubKey_args");
- xfer += oprot->writeFieldBegin("updatedProject", ::apache::thrift::protocol::T_STRUCT, 2);
- xfer += this->updatedProject.write(oprot);
+ xfer += oprot->writeFieldBegin("airavataCredStoreToken", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->airavataCredStoreToken);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -1879,16 +1883,12 @@ uint32_t Airavata_updateProject_args::write(::apache::thrift::protocol::TProtoco
return xfer;
}
-uint32_t Airavata_updateProject_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getSSHPubKey_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_updateProject_pargs");
-
- xfer += oprot->writeFieldBegin("projectId", ::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString((*(this->projectId)));
- xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeStructBegin("Airavata_getSSHPubKey_pargs");
- xfer += oprot->writeFieldBegin("updatedProject", ::apache::thrift::protocol::T_STRUCT, 2);
- xfer += (*(this->updatedProject)).write(oprot);
+ xfer += oprot->writeFieldBegin("airavataCredStoreToken", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->airavataCredStoreToken)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -1896,7 +1896,7 @@ uint32_t Airavata_updateProject_pargs::write(::apache::thrift::protocol::TProtoc
return xfer;
}
-uint32_t Airavata_updateProject_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getSSHPubKey_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -1916,6 +1916,14 @@ uint32_t Airavata_updateProject_result::read(::apache::thrift::protocol::TProtoc
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -1940,14 +1948,6 @@ uint32_t Airavata_updateProject_result::read(::apache::thrift::protocol::TProtoc
xfer += iprot->skip(ftype);
}
break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->pnfe.read(iprot);
- this->__isset.pnfe = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
default:
xfer += iprot->skip(ftype);
break;
@@ -1960,13 +1960,17 @@ uint32_t Airavata_updateProject_result::read(::apache::thrift::protocol::TProtoc
return xfer;
}
-uint32_t Airavata_updateProject_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getSSHPubKey_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_updateProject_result");
+ xfer += oprot->writeStructBegin("Airavata_getSSHPubKey_result");
- if (this->__isset.ire) {
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->ire.write(oprot);
xfer += oprot->writeFieldEnd();
@@ -1978,17 +1982,13 @@ uint32_t Airavata_updateProject_result::write(::apache::thrift::protocol::TProto
xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->ase.write(oprot);
xfer += oprot->writeFieldEnd();
- } else if (this->__isset.pnfe) {
- xfer += oprot->writeFieldBegin("pnfe", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += this->pnfe.write(oprot);
- xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
-uint32_t Airavata_updateProject_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getSSHPubKey_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -2008,6 +2008,14 @@ uint32_t Airavata_updateProject_presult::read(::apache::thrift::protocol::TProto
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -2032,14 +2040,6 @@ uint32_t Airavata_updateProject_presult::read(::apache::thrift::protocol::TProto
xfer += iprot->skip(ftype);
}
break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->pnfe.read(iprot);
- this->__isset.pnfe = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
default:
xfer += iprot->skip(ftype);
break;
@@ -2052,7 +2052,7 @@ uint32_t Airavata_updateProject_presult::read(::apache::thrift::protocol::TProto
return xfer;
}
-uint32_t Airavata_getProject_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getAllUserSSHPubKeys_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -2063,7 +2063,7 @@ uint32_t Airavata_getProject_args::read(::apache::thrift::protocol::TProtocol* i
using ::apache::thrift::protocol::TProtocolException;
- bool isset_projectId = false;
+ bool isset_userName = false;
while (true)
{
@@ -2075,8 +2075,8 @@ uint32_t Airavata_getProject_args::read(::apache::thrift::protocol::TProtocol* i
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->projectId);
- isset_projectId = true;
+ xfer += iprot->readString(this->userName);
+ isset_userName = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -2090,17 +2090,17 @@ uint32_t Airavata_getProject_args::read(::apache::thrift::protocol::TProtocol* i
xfer += iprot->readStructEnd();
- if (!isset_projectId)
+ if (!isset_userName)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_getProject_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getAllUserSSHPubKeys_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_getProject_args");
+ xfer += oprot->writeStructBegin("Airavata_getAllUserSSHPubKeys_args");
- xfer += oprot->writeFieldBegin("projectId", ::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->projectId);
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->userName);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -2108,12 +2108,12 @@ uint32_t Airavata_getProject_args::write(::apache::thrift::protocol::TProtocol*
return xfer;
}
-uint32_t Airavata_getProject_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getAllUserSSHPubKeys_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_getProject_pargs");
+ xfer += oprot->writeStructBegin("Airavata_getAllUserSSHPubKeys_pargs");
- xfer += oprot->writeFieldBegin("projectId", ::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString((*(this->projectId)));
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->userName)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -2121,7 +2121,7 @@ uint32_t Airavata_getProject_pargs::write(::apache::thrift::protocol::TProtocol*
return xfer;
}
-uint32_t Airavata_getProject_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getAllUserSSHPubKeys_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -2142,8 +2142,741 @@ uint32_t Airavata_getProject_result::read(::apache::thrift::protocol::TProtocol*
switch (fid)
{
case 0:
+ if (ftype == ::apache::thrift::protocol::T_MAP) {
+ {
+ this->success.clear();
+ uint32_t _size11;
+ ::apache::thrift::protocol::TType _ktype12;
+ ::apache::thrift::protocol::TType _vtype13;
+ xfer += iprot->readMapBegin(_ktype12, _vtype13, _size11);
+ uint32_t _i15;
+ for (_i15 = 0; _i15 < _size11; ++_i15)
+ {
+ std::string _key16;
+ xfer += iprot->readString(_key16);
+ std::string& _val17 = this->success[_key16];
+ xfer += iprot->readString(_val17);
+ }
+ xfer += iprot->readMapEnd();
+ }
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->success.read(iprot);
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_getAllUserSSHPubKeys_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+
+ uint32_t xfer = 0;
+
+ xfer += oprot->writeStructBegin("Airavata_getAllUserSSHPubKeys_result");
+
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
+ {
+ xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
+ std::map<std::string, std::string> ::const_iterator _iter18;
+ for (_iter18 = this->success.begin(); _iter18 != this->success.end(); ++_iter18)
+ {
+ xfer += oprot->writeString(_iter18->first);
+ xfer += oprot->writeString(_iter18->second);
+ }
+ xfer += oprot->writeMapEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
+ xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
+ xfer += this->ire.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ace) {
+ xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->ace.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ase) {
+ xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += this->ase.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_getAllUserSSHPubKeys_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_MAP) {
+ {
+ (*(this->success)).clear();
+ uint32_t _size19;
+ ::apache::thrift::protocol::TType _ktype20;
+ ::apache::thrift::protocol::TType _vtype21;
+ xfer += iprot->readMapBegin(_ktype20, _vtype21, _size19);
+ uint32_t _i23;
+ for (_i23 = 0; _i23 < _size19; ++_i23)
+ {
+ std::string _key24;
+ xfer += iprot->readString(_key24);
+ std::string& _val25 = (*(this->success))[_key24];
+ xfer += iprot->readString(_val25);
+ }
+ xfer += iprot->readMapEnd();
+ }
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_createProject_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_project = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->project.read(iprot);
+ isset_project = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_project)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Airavata_createProject_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_createProject_args");
+
+ xfer += oprot->writeFieldBegin("project", ::apache::thrift::protocol::T_STRUCT, 1);
+ xfer += this->project.write(oprot);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_createProject_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_createProject_pargs");
+
+ xfer += oprot->writeFieldBegin("project", ::apache::thrift::protocol::T_STRUCT, 1);
+ xfer += (*(this->project)).write(oprot);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_createProject_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_createProject_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+
+ uint32_t xfer = 0;
+
+ xfer += oprot->writeStructBegin("Airavata_createProject_result");
+
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
+ xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
+ xfer += this->ire.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ace) {
+ xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->ace.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ase) {
+ xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += this->ase.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_createProject_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_updateProject_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_projectId = false;
+ bool isset_updatedProject = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->projectId);
+ isset_projectId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->updatedProject.read(iprot);
+ isset_updatedProject = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_projectId)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_updatedProject)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Airavata_updateProject_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_updateProject_args");
+
+ xfer += oprot->writeFieldBegin("projectId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->projectId);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("updatedProject", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->updatedProject.write(oprot);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_updateProject_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_updateProject_pargs");
+
+ xfer += oprot->writeFieldBegin("projectId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->projectId)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("updatedProject", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += (*(this->updatedProject)).write(oprot);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_updateProject_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->pnfe.read(iprot);
+ this->__isset.pnfe = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_updateProject_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+
+ uint32_t xfer = 0;
+
+ xfer += oprot->writeStructBegin("Airavata_updateProject_result");
+
+ if (this->__isset.ire) {
+ xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
+ xfer += this->ire.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ace) {
+ xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->ace.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ase) {
+ xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += this->ase.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.pnfe) {
+ xfer += oprot->writeFieldBegin("pnfe", ::apache::thrift::protocol::T_STRUCT, 4);
+ xfer += this->pnfe.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_updateProject_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->pnfe.read(iprot);
+ this->__isset.pnfe = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_getProject_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_projectId = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->projectId);
+ isset_projectId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_projectId)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Airavata_getProject_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_getProject_args");
+
+ xfer += oprot->writeFieldBegin("projectId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->projectId);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_getProject_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_getProject_pargs");
+
+ xfer += oprot->writeFieldBegin("projectId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->projectId)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_getProject_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->success.read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -2390,14 +3123,14 @@ uint32_t Airavata_getAllUserProjects_result::read(::apache::thrift::protocol::TP
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size11;
- ::apache::thrift::protocol::TType _etype14;
- xfer += iprot->readListBegin(_etype14, _size11);
- this->success.resize(_size11);
- uint32_t _i15;
- for (_i15 = 0; _i15 < _size11; ++_i15)
+ uint32_t _size26;
+ ::apache::thrift::protocol::TType _etype29;
+ xfer += iprot->readListBegin(_etype29, _size26);
+ this->success.resize(_size26);
+ uint32_t _i30;
+ for (_i30 = 0; _i30 < _size26; ++_i30)
{
- xfer += this->success[_i15].read(iprot);
+ xfer += this->success[_i30].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -2452,10 +3185,10 @@ uint32_t Airavata_getAllUserProjects_result::write(::apache::thrift::protocol::T
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::Project> ::const_iterator _iter16;
- for (_iter16 = this->success.begin(); _iter16 != this->success.end(); ++_iter16)
+ std::vector< ::apache::airavata::model::workspace::Project> ::const_iterator _iter31;
+ for (_iter31 = this->success.begin(); _iter31 != this->success.end(); ++_iter31)
{
- xfer += (*_iter16).write(oprot);
+ xfer += (*_iter31).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -2502,14 +3235,14 @@ uint32_t Airavata_getAllUserProjects_presult::read(::apache::thrift::protocol::T
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size17;
- ::apache::thrift::protocol::TType _etype20;
- xfer += iprot->readListBegin(_etype20, _size17);
- (*(this->success)).resize(_size17);
- uint32_t _i21;
- for (_i21 = 0; _i21 < _size17; ++_i21)
+ uint32_t _size32;
+ ::apache::thrift::protocol::TType _etype35;
+ xfer += iprot->readListBegin(_etype35, _size32);
+ (*(this->success)).resize(_size32);
+ uint32_t _i36;
+ for (_i36 = 0; _i36 < _size32; ++_i36)
{
- xfer += (*(this->success))[_i21].read(iprot);
+ xfer += (*(this->success))[_i36].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -2666,14 +3399,14 @@ uint32_t Airavata_searchProjectsByProjectName_result::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size22;
- ::apache::thrift::protocol::TType _etype25;
- xfer += iprot->readListBegin(_etype25, _size22);
- this->success.resize(_size22);
- uint32_t _i26;
- for (_i26 = 0; _i26 < _size22; ++_i26)
+ uint32_t _size37;
+ ::apache::thrift::protocol::TType _etype40;
+ xfer += iprot->readListBegin(_etype40, _size37);
+ this->success.resize(_size37);
+ uint32_t _i41;
+ for (_i41 = 0; _i41 < _size37; ++_i41)
{
- xfer += this->success[_i26].read(iprot);
+ xfer += this->success[_i41].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -2728,10 +3461,10 @@ uint32_t Airavata_searchProjectsByProjectName_result::write(::apache::thrift::pr
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::Project> ::const_iterator _iter27;
- for (_iter27 = this->success.begin(); _iter27 != this->success.end(); ++_iter27)
+ std::vector< ::apache::airavata::model::workspace::Project> ::const_iterator _iter42;
+ for (_iter42 = this->success.begin(); _iter42 != this->success.end(); ++_iter42)
{
- xfer += (*_iter27).write(oprot);
+ xfer += (*_iter42).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -2778,14 +3511,14 @@ uint32_t Airavata_searchProjectsByProjectName_presult::read(::apache::thrift::pr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size28;
- ::apache::thrift::protocol::TType _etype31;
- xfer += iprot->readListBegin(_etype31, _size28);
- (*(this->success)).resize(_size28);
- uint32_t _i32;
- for (_i32 = 0; _i32 < _size28; ++_i32)
+ uint32_t _size43;
+ ::apache::thrift::protocol::TType _etype46;
+ xfer += iprot->readListBegin(_etype46, _size43);
+ (*(this->success)).resize(_size43);
+ uint32_t _i47;
+ for (_i47 = 0; _i47 < _size43; ++_i47)
{
- xfer += (*(this->success))[_i32].read(iprot);
+ xfer += (*(this->success))[_i47].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -2942,14 +3675,14 @@ uint32_t Airavata_searchProjectsByProjectDesc_result::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size33;
- ::apache::thrift::protocol::TType _etype36;
- xfer += iprot->readListBegin(_etype36, _size33);
- this->success.resize(_size33);
- uint32_t _i37;
- for (_i37 = 0; _i37 < _size33; ++_i37)
+ uint32_t _size48;
+ ::apache::thrift::protocol::TType _etype51;
+ xfer += iprot->readListBegin(_etype51, _size48);
+ this->success.resize(_size48);
+ uint32_t _i52;
+ for (_i52 = 0; _i52 < _size48; ++_i52)
{
- xfer += this->success[_i37].read(iprot);
+ xfer += this->success[_i52].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3004,10 +3737,10 @@ uint32_t Airavata_searchProjectsByProjectDesc_result::write(::apache::thrift::pr
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::Project> ::const_iterator _iter38;
- for (_iter38 = this->success.begin(); _iter38 != this->success.end(); ++_iter38)
+ std::vector< ::apache::airavata::model::workspace::Project> ::const_iterator _iter53;
+ for (_iter53 = this->success.begin(); _iter53 != this->success.end(); ++_iter53)
{
- xfer += (*_iter38).write(oprot);
+ xfer += (*_iter53).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -3054,14 +3787,14 @@ uint32_t Airavata_searchProjectsByProjectDesc_presult::read(::apache::thrift::pr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size39;
- ::apache::thrift::protocol::TType _etype42;
- xfer += iprot->readListBegin(_etype42, _size39);
- (*(this->success)).resize(_size39);
- uint32_t _i43;
- for (_i43 = 0; _i43 < _size39; ++_i43)
+ uint32_t _size54;
+ ::apache::thrift::protocol::TType _etype57;
+ xfer += iprot->readListBegin(_etype57, _size54);
+ (*(this->success)).resize(_size54);
+ uint32_t _i58;
+ for (_i58 = 0; _i58 < _size54; ++_i58)
{
- xfer += (*(this->success))[_i43].read(iprot);
+ xfer += (*(this->success))[_i58].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3218,14 +3951,14 @@ uint32_t Airavata_searchExperimentsByName_result::read(::apache::thrift::protoco
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size44;
- ::apache::thrift::protocol::TType _etype47;
- xfer += iprot->readListBegin(_etype47, _size44);
- this->success.resize(_size44);
- uint32_t _i48;
- for (_i48 = 0; _i48 < _size44; ++_i48)
+ uint32_t _size59;
+ ::apache::thrift::protocol::TType _etype62;
+ xfer += iprot->readListBegin(_etype62, _size59);
+ this->success.resize(_size59);
+ uint32_t _i63;
+ for (_i63 = 0; _i63 < _size59; ++_i63)
{
- xfer += this->success[_i48].read(iprot);
+ xfer += this->success[_i63].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3280,10 +4013,10 @@ uint32_t Airavata_searchExperimentsByName_result::write(::apache::thrift::protoc
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> ::const_iterator _iter49;
- for (_iter49 = this->success.begin(); _iter49 != this->success.end(); ++_iter49)
+ std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> ::const_iterator _iter64;
+ for (_iter64 = this->success.begin(); _iter64 != this->success.end(); ++_iter64)
{
- xfer += (*_iter49).write(oprot);
+ xfer += (*_iter64).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -3330,14 +4063,14 @@ uint32_t Airavata_searchExperimentsByName_presult::read(::apache::thrift::protoc
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size50;
- ::apache::thrift::protocol::TType _etype53;
- xfer += iprot->readListBegin(_etype53, _size50);
- (*(this->success)).resize(_size50);
- uint32_t _i54;
- for (_i54 = 0; _i54 < _size50; ++_i54)
+ uint32_t _size65;
+ ::apache::thrift::protocol::TType _etype68;
+ xfer += iprot->readListBegin(_etype68, _size65);
+ (*(this->success)).resize(_size65);
+ uint32_t _i69;
+ for (_i69 = 0; _i69 < _size65; ++_i69)
{
- xfer += (*(this->success))[_i54].read(iprot);
+ xfer += (*(this->success))[_i69].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3494,14 +4227,14 @@ uint32_t Airavata_searchExperimentsByDesc_result::read(::apache::thrift::protoco
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size55;
- ::apache::thrift::protocol::TType _etype58;
- xfer += iprot->readListBegin(_etype58, _size55);
- this->success.resize(_size55);
- uint32_t _i59;
- for (_i59 = 0; _i59 < _size55; ++_i59)
+ uint32_t _size70;
+ ::apache::thrift::protocol::TType _etype73;
+ xfer += iprot->readListBegin(_etype73, _size70);
+ this->success.resize(_size70);
+ uint32_t _i74;
+ for (_i74 = 0; _i74 < _size70; ++_i74)
{
- xfer += this->success[_i59].read(iprot);
+ xfer += this->success[_i74].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3556,10 +4289,10 @@ uint32_t Airavata_searchExperimentsByDesc_result::write(::apache::thrift::protoc
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> ::const_iterator _iter60;
- for (_iter60 = this->success.begin(); _iter60 != this->success.end(); ++_iter60)
+ std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> ::const_iterator _iter75;
+ for (_iter75 = this->success.begin(); _iter75 != this->success.end(); ++_iter75)
{
- xfer += (*_iter60).write(oprot);
+ xfer += (*_iter75).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -3606,14 +4339,14 @@ uint32_t Airavata_searchExperimentsByDesc_presult::read(::apache::thrift::protoc
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size61;
- ::apache::thrift::protocol::TType _etype64;
- xfer += iprot->readListBegin(_etype64, _size61);
- (*(this->success)).resize(_size61);
- uint32_t _i65;
- for (_i65 = 0; _i65 < _size61; ++_i65)
+ uint32_t _size76;
+ ::apache::thrift::protocol::TType _etype79;
+ xfer += iprot->readListBegin(_etype79, _size76);
+ (*(this->success)).resize(_size76);
+ uint32_t _i80;
+ for (_i80 = 0; _i80 < _size76; ++_i80)
{
- xfer += (*(this->success))[_i65].read(iprot);
+ xfer += (*(this->success))[_i80].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3770,14 +4503,14 @@ uint32_t Airavata_searchExperimentsByApplication_result::read(::apache::thrift::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size66;
- ::apache::thrift::protocol::TType _etype69;
- xfer += iprot->readListBegin(_etype69, _size66);
- this->success.resize(_size66);
- uint32_t _i70;
- for (_i70 = 0; _i70 < _size66; ++_i70)
+ uint32_t _size81;
+ ::apache::thrift::protocol::TType _etype84;
+ xfer += iprot->readListBegin(_etype84, _size81);
+ this->success.resize(_size81);
+ uint32_t _i85;
+ for (_i85 = 0; _i85 < _size81; ++_i85)
{
- xfer += this->success[_i70].read(iprot);
+ xfer += this->success[_i85].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3832,10 +4565,10 @@ uint32_t Airavata_searchExperimentsByApplication_result::write(::apache::thrift:
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> ::const_iterator _iter71;
- for (_iter71 = this->success.begin(); _iter71 != this->success.end(); ++_iter71)
+ std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> ::const_iterator _iter86;
+ for (_iter86 = this->success.begin(); _iter86 != this->success.end(); ++_iter86)
{
- xfer += (*_iter71).write(oprot);
+ xfer += (*_iter86).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -3882,14 +4615,14 @@ uint32_t Airavata_searchExperimentsByApplication_presult::read(::apache::thrift:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size72;
- ::apache::thrift::protocol::TType _etype75;
- xfer += iprot->readListBegin(_etype75, _size72);
- (*(this->success)).resize(_size72);
- uint32_t _i76;
- for (_i76 = 0; _i76 < _size72; ++_i76)
+ uint32_t _size87;
+ ::apache::thrift::protocol::TType _etype90;
+ xfer += iprot->readListBegin(_etype90, _size87);
+ (*(this->success)).resize(_size87);
+ uint32_t _i91;
+ for (_i91 = 0; _i91 < _size87; ++_i91)
{
- xfer += (*(this->success))[_i76].read(iprot);
+ xfer += (*(this->success))[_i91].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3966,9 +4699,9 @@ uint32_t Airavata_searchExperimentsByStatus_args::read(::apache::thrift::protoco
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast77;
- xfer += iprot->readI32(ecast77);
- this->experimentState = ( ::apache::airavata::model::workspace::experiment::ExperimentState::type)ecast77;
+ int32_t ecast92;
+ xfer += iprot->readI32(ecast92);
+ this->experimentState = ( ::apache::airavata::model::workspace::experiment::ExperimentState::type)ecast92;
isset_experimentState = true;
} else {
xfer += iprot->skip(ftype);
@@ -4048,14 +4781,14 @@ uint32_t Airavata_searchExperimentsByStatus_result::read(::apache::thrift::proto
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size78;
- ::apache::thrift::protocol::TType _etype81;
- xfer += iprot->readListBegin(_etype81, _size78);
- this->success.resize(_size78);
- uint32_t _i82;
- for (_i82 = 0; _i82 < _size78; ++_i82)
+ uint32_t _size93;
+ ::apache::thrift::protocol::TType _etype96;
+ xfer += iprot->readListBegin(_etype96, _size93);
+ this->success.resize(_size93);
+ uint32_t _i97;
+ for (_i97 = 0; _i97 < _size93; ++_i97)
{
- xfer += this->success[_i82].read(iprot);
+ xfer += this->success[_i97].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -4110,10 +4843,10 @@ uint32_t Airavata_searchExperimentsByStatus_result::write(::apache::thrift::prot
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> ::const_iterator _iter83;
- for (_iter83 = this->success.begin(); _iter83 != this->success.end(); ++_iter83)
+ std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> ::const_iterator _iter98;
+ for (_iter98 = this->success.begin(); _iter98 != this->success.end(); ++_iter98)
{
- xfer += (*_iter83).write(oprot);
+ xfer += (*_iter98).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -4160,14 +4893,14 @@ uint32_t Airavata_searchExperimentsByStatus_presult::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size84;
- ::apache::thrift::protocol::TType _etype87;
- xfer += iprot->readListBegin(_etype87, _size84);
- (*(this->success)).resize(_size84);
- uint32_t _i88;
- for (_i88 = 0; _i88 < _size84; ++_i88)
+ uint32_t _size99;
+ ::apache::thrift::protocol::TType _etype102;
+ xfer += iprot->readListBegin(_etype102, _size99);
+ (*(this->success)).resize(_size99);
+ uint32_t _i103;
+ for (_i103 = 0; _i103 < _size99; ++_i103)
{
- xfer += (*(this->success))[_i88].read(iprot);
+ xfer += (*(this->success))[_i103].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -4343,14 +5076,14 @@ uint32_t Airavata_searchExperimentsByCreationTime_result::read(::apache::thrift:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size89;
- ::apache::thrift::protocol::TType _etype92;
- xfer += iprot->readListBegin(_etype92, _size89);
- this->success.resize(_size89);
- uint32_t _i93;
- for (_i93 = 0; _i93 < _size89; ++_i93)
+ uint32_t _size104;
+ ::apache::thrift::protocol::TType _etype107;
+ xfer += iprot->readListBegin(_etype107, _size104);
+ this->success.resize(_size104);
+ uint32_t _i108;
+ for (_i108 = 0; _i108 < _size104; ++_i108)
{
- xfer += this->success[_i93].read(iprot);
+ xfer += this->success[_i108].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -4405,10 +5138,10 @@ uint32_t Airavata_searchExperimentsByCreationTime_result::write(::apache::thrift
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> ::const_iterator _iter94;
- for (_iter94 = this->success.begin(); _iter94 != this->success.end(); ++_iter94)
+ std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> ::const_iterator _iter109;
+ for (_iter109 = this->success.begin(); _iter109 != this->success.end(); ++_iter109)
{
- xfer += (*_iter94).write(oprot);
+ xfer += (*_iter109).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -4455,14 +5188,14 @@ uint32_t Airavata_searchExperimentsByCreationTime_presult::read(::apache::thrift
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size95;
- ::apache::thrift::protocol::TType _etype98;
- xfer += iprot->readListBegin(_etype98, _size95);
- (*(this->success)).resize(_size95);
- uint32_t _i99;
- for (_i99 = 0; _i99 < _size95; ++_i99)
+ uint32_t _size110;
+ ::apache::thrift::protocol::TType _etype113;
+ xfer += iprot->readListBegin(_etype113, _size110);
+ (*(this->success)).resize(_size110);
+ uint32_t _i114;
+ for (_i114 = 0; _i114 < _size110; ++_i114)
{
- xfer += (*(this->success))[_i99].read(iprot);
+ xfer += (*(this->success))[_i114].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -4600,14 +5333,14 @@ uint32_t Airavata_getAllExperimentsInProject_result::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size100;
- ::apache::thrift::protocol::TType _etype103;
- xfer += iprot->readListBegin(_etype103, _size100);
- this->success.resize(_size100);
- uint32_t _i104;
- for (_i104 = 0; _i104 < _size100; ++_i104)
+ uint32_t _size115;
+ ::apache::thrift::protocol::TType _etype118;
+ xfer += iprot->readListBegin(_etype118, _size115);
+ this->success.resize(_size115);
+ uint32_t _i119;
+ for (_i119 = 0; _i119 < _size115; ++_i119)
{
- xfer += this->success[_i104].read(iprot);
+ xfer += this->success[_i119].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -4670,10 +5403,10 @@ uint32_t Airavata_getAllExperimentsInProject_result::write(::apache::thrift::pro
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter105;
- for (_iter105 = this->success.begin(); _iter105 != this->success.end(); ++_iter105)
+ std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter120;
+ for (_iter120 = this->success.begin(); _iter120 != this->success.end(); ++_iter120)
{
- xfer += (*_iter105).write(oprot);
+ xfer += (*_iter120).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -4724,14 +5457,14 @@ uint32_t Airavata_getAllExperimentsInProject_presult::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size106;
- ::apache::thrift::protocol::TType _etype109;
- xfer += iprot->readListBegin(_etype109, _size106);
- (*(this->success)).resize(_size106);
- uint32_t _i110;
- for (_i110 = 0; _i110 < _size106; ++_i110)
+ uint32_t _size121;
+ ::apache::thrift::protocol::TType _etype124;
+ xfer += iprot->readListBegin(_etype124, _size121);
+ (*(this->success)).resize(_size121);
+ uint32_t _i125;
+ for (_i125 = 0; _i125 < _size121; ++_i125)
{
- xfer += (*(this->success))[_i110].read(iprot);
+ xfer += (*(this->success))[_i125].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -4877,14 +5610,14 @@ uint32_t Airavata_getAllUserExperiments_result::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size111;
- ::apache::thrift::protocol::TType _etype114;
- xfer += iprot->readListBegin(_etype114, _size111);
- this->success.resize(_size111);
- uint32_t _i115;
- for (_i115 = 0; _i115 < _size111; ++_i115)
+ uint32_t _size126;
+ ::apache::thrift::protocol::TType _etype129;
+ xfer += iprot->readListBegin(_etype129, _size126);
+ this->success.resize(_size126);
+ uint32_t _i130;
+ for (_i130 = 0; _i130 < _size126; ++_i130)
{
- xfer += this->success[_i115].read(iprot);
+ xfer += this->success[_i130].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -4939,10 +5672,10 @@ uint32_t Airavata_getAllUserExperiments_result::write(::apache::thrift::protocol
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter116;
- for (_iter116 = this->success.begin(); _iter116 != this->success.end(); ++_iter116)
+ std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter131;
+ for (_iter131 = this->success.begin(); _iter131 != this->success.end(); ++_iter131)
{
- xfer += (*_iter116).write(oprot);
+ xfer += (*_iter131).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -4989,14 +5722,14 @@ uint32_t Airavata_getAllUserExperiments_presult::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size117;
- ::apache::thrift::protocol::TType _etype120;
- xfer += iprot->readListBegin(_etype120, _size117);
- (*(this->success)).resize(_size117);
- uint32_t _i121;
- for (_i121 = 0; _i121 < _size117; ++_i121)
+ uint32_t _size132;
+ ::apache::thrift::protocol::TType _etype135;
+ xfer += iprot->readListBegin(_etype135, _size132);
+ (*(this->success)).resize(_size132);
+ uint32_t _i136;
+ for (_i136 = 0; _i136 < _size132; ++_i136)
{
- xfer += (*(this->success))[_i121].read(iprot);
+ xfer += (*(this->success))[_i136].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -6908,14 +7641,14 @@ uint32_t Airavata_getExperimentOutputs_result::read(::apache::thrift::protocol::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size122;
- ::apache::thrift::protocol::TType _etype125;
- xfer += iprot->readListBegin(_etype125, _size122);
- this->success.resize(_size122);
- uint32_t _i126;
- for (_i126 = 0; _i126 < _size122; ++_i126)
+ uint32_t _size137;
+ ::apache::thrift::protocol::TType _etype140;
+ xfer += iprot->readListBegin(_etype140, _size137);
+ this->success.resize(_size137);
+ uint32_t _i141;
+ for (_i141 = 0; _i141 < _size137; ++_i141)
{
- xfer += this->success[_i126].read(iprot);
+ xfer += this->success[_i141].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -6978,10 +7711,10 @@ uint32_t Airavata_getExperimentOutputs_result::write(::apache::thrift::protocol:
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter127;
- for (_iter127 = this->success.begin(); _iter127 != this->success.end(); ++_iter127)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter142;
+ for (_iter142 = this->success.begin(); _iter142 != this->success.end(); ++_iter142)
{
- xfer += (*_iter127).write(oprot);
+ xfer += (*_iter142).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -7032,14 +7765,14 @@ uint32_t Airavata_getExperimentOutputs_presult::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size128;
- ::apache::thrift::protocol::TType _etype131;
- xfer += iprot->readListBegin(_etype131, _size128);
- (*(this->success)).resize(_size128);
- uint32_t _i132;
- for (_i132 = 0; _i132 < _size128; ++_i132)
+ uint32_t _size143;
+ ::apache::thrift::protocol::TType _etype146;
+ xfer += iprot->readListBegin(_etype146, _size143);
+ (*(this->success)).resize(_size143);
+ uint32_t _i147;
+ for (_i147 = 0; _i147 < _size143; ++_i147)
{
- xfer += (*(this->success))[_i132].read(iprot);
+ xfer += (*(this->success))[_i147].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -7185,14 +7918,14 @@ uint32_t Airavata_getIntermediateOutputs_result::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size133;
- ::apache::thrift::protocol::TType _etype136;
- xfer += iprot->readListBegin(_etype136, _size133);
- this->success.resize(_size133);
- uint32_t _i137;
- for (_i137 = 0; _i137 < _size133; ++_i137)
+ uint32_t _size148;
+ ::apache::thrift::protocol::TType _etype151;
+ xfer += iprot->readListBegin(_etype151, _size148);
+ this->success.resize(_size148);
+ uint32_t _i152;
+ for (_i152 = 0; _i152 < _size148; ++_i152)
{
- xfer += this->success[_i137].read(iprot);
+ xfer += this->success[_i152].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -7255,10 +7988,10 @@ uint32_t Airavata_getIntermediateOutputs_result::write(::apache::thrift::protoco
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter138;
- for (_iter138 = this->success.begin(); _iter138 != this->success.end(); ++_iter138)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter153;
+ for (_iter153 = this->success.begin(); _iter153 != this->success.end(); ++_iter153)
{
- xfer += (*_iter138).write(oprot);
+ xfer += (*_iter153).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -7309,14 +8042,14 @@ uint32_t Airavata_getIntermediateOutputs_presult::read(::apache::thrift::protoco
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size139;
- ::apache::thrift::protocol::TType _etype142;
- xfer += iprot->readListBegin(_etype142, _size139);
- (*(this->success)).resize(_size139);
- uint32_t _i143;
- for (_i143 = 0; _i143 < _size139; ++_i143)
+ uint32_t _size154;
+ ::apache::thrift::protocol::TType _etype157;
+ xfer += iprot->readListBegin(_etype157, _size154);
+ (*(this->success)).resize(_size154);
+ uint32_t _i158;
+ for (_i158 = 0; _i158 < _size154; ++_i158)
{
- xfer += (*(this->success))[_i143].read(iprot);
+ xfer += (*(this->success))[_i158].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -7462,17 +8195,17 @@ uint32_t Airavata_getJobStatuses_result::read(::apache::thrift::protocol::TProto
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size144;
- ::apache::thrift::protocol::TType _ktype145;
- ::apache::thrift::protocol::TType _vtype146;
- xfer += iprot->readMapBegin(_ktype145, _vtype146, _size144);
- uint32_t _i148;
- for (_i148 = 0; _i148 < _size144; ++_i148)
+ uint32_t _size159;
+ ::apache::thrift::protocol::TType _ktype160;
+ ::apache::thrift::protocol::TType _vtype161;
+ xfer += iprot->readMapBegin(_ktype160, _vtype161, _size159);
+ uint32_t _i163;
+ for (_i163 = 0; _i163 < _size159; ++_i163)
{
- std::string _key149;
- xfer += iprot->readString(_key149);
- ::apache::airavata::model::workspace::experiment::JobStatus& _val150 = this->success[_key149];
- xfer += _val150.read(iprot);
+ std::string _key164;
+ xfer += iprot->readString(_key164);
+ ::apache::airavata::model::workspace::experiment::JobStatus& _val165 = this->success[_key164];
+ xfer += _val165.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -7535,11 +8268,11 @@ uint32_t Airavata_getJobStatuses_result::write(::apache::thrift::protocol::TProt
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> ::const_iterator _iter151;
- for (_iter151 = this->success.begin(); _iter151 != this->success.end(); ++_iter151)
+ std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> ::const_iterator _iter166;
+ for (_iter166 = this->success.begin(); _iter166 != this->success.end(); ++_iter166)
{
- xfer += oprot->writeString(_iter151->first);
- xfer += _iter151->second.write(oprot);
+ xfer += oprot->writeString(_iter166->first);
+ xfer += _iter166->second.write(oprot);
}
xfer += oprot->writeMapEnd();
}
@@ -7590,17 +8323,17 @@ uint32_t Airavata_getJobStatuses_presult::read(::apache::thrift::protocol::TProt
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size152;
- ::apache::thrift::protocol::TType _ktype153;
- ::apache::thrift::protocol::TType _vtype154;
- xfer += iprot->readMapBegin(_ktype153, _vtype154, _size152);
- uint32_t _i156;
- for (_i156 = 0; _i156 < _size152; ++_i156)
+ uint32_t _size167;
+ ::apache::thrift::protocol::TType _ktype168;
+ ::apache::thrift::protocol::TType _vtype169;
+ xfer += iprot->readMapBegin(_ktype168, _vtype169, _size167);
+ uint32_t _i171;
+ for (_i171 = 0; _i171 < _size167; ++_i171)
{
- std::string _key157;
- xfer += iprot->readString(_key157);
- ::apache::airavata::model::workspace::experiment::JobStatus& _val158 = (*(this->success))[_key157];
- xfer += _val158.read(iprot);
+ std::string _key172;
+ xfer += iprot->readString(_key172);
+ ::apache::airavata::model::workspace::experiment::JobStatus& _val173 = (*(this->success))[_key172];
+ xfer += _val173.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -7746,14 +8479,14 @@ uint32_t Airavata_getJobDetails_result::read(::apache::thrift::protocol::TProtoc
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size159;
- ::apache::thrift::protocol::TType _etype162;
- xfer += iprot->readListBegin(_etype162, _size159);
- this->success.resize(_size159);
- uint32_t _i163;
- for (_i163 = 0; _i163 < _size159; ++_i163)
+ uint32_t _size174;
+ ::apache::thrift::protocol::TType _etype177;
+ xfer += iprot->readListBegin(_etype177, _size174);
+ this->success.resize(_size174);
+ uint32_t _i178;
+ for (_i178 = 0; _i178 < _size174; ++_i178)
{
- xfer += this->success[_i163].read(iprot);
+ xfer += this->success[_i178].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -7816,10 +8549,10 @@ uint32_t Airavata_getJobDetails_result::write(::apache::thrift::protocol::TProto
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::JobDetails> ::const_iterator _iter164;
- for (_iter164 = this->success.begin(); _iter164 != this->success.end(); ++_iter164)
+ std::vector< ::apache::airavata::model::workspace::experiment::JobDetails> ::const_iterator _iter179;
+ for (_iter179 = this->success.begin(); _iter179 != this->success.end(); ++_iter179)
{
- xfer += (*_iter164).write(oprot);
+ xfer += (*_iter179).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -7870,14 +8603,14 @@ uint32_t Airavata_getJobDetails_presult::read(::apache::thrift::protocol::TProto
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size165;
- ::apache::thrift::protocol::TType _etype168;
- xfer += iprot->readListBegin(_etype168, _size165);
- (*(this->success)).resize(_size165);
- uint32_t _i169;
- for (_i169 = 0; _i169 < _size165; ++_i169)
+ uint32_t _size180;
+ ::apache::thrift::protocol::TType _etype183;
+ xfer += iprot->readListBegin(_etype183, _size180);
+ (*(this->success)).resize(_size180);
+ uint32_t _i184;
+ for (_i184 = 0; _i184 < _size180; ++_i184)
{
- xfer += (*(this->success))[_i169].read(iprot);
+ xfer += (*(this->success))[_i184].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -8023,14 +8756,14 @@ uint32_t Airavata_getDataTransferDetails_result::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size170;
- ::apache::thrift::protocol::TType _etype173;
- xfer += iprot->readListBegin(_etype173, _size170);
- this->success.resize(_size170);
- uint32_t _i174;
- for (_i174 = 0; _i174 < _size170; ++_i174)
+ uint32_t _size185;
+ ::apache::thrift::protocol::TType _etype188;
+ xfer += iprot->readListBegin(_etype188, _size185);
+ this->success.resize(_size185);
+ uint32_t _i189;
+ for (_i189 = 0; _i189 < _size185; ++_i189)
{
- xfer += this->success[_i174].read(iprot);
+ xfer += this->success[_i189].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -8093,10 +8826,10 @@ uint32_t Airavata_getDataTransferDetails_result::write(::apache::thrift::protoco
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::DataTransferDetails> ::const_iterator _iter175;
- for (_iter175 = this->success.begin(); _iter175 != this->success.end(); ++_iter175)
+ std::vector< ::apache::airavata::model::workspace::experiment::DataTransferDetails> ::const_iterator _iter190;
+ for (_iter190 = this->success.begin(); _iter190 != this->success.end(); ++_iter190)
{
- xfer += (*_iter175).write(oprot);
+ xfer += (*_iter190).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -8147,14 +8880,14 @@ uint32_t Airavata_getDataTransferDetails_presult::read(::apache::thrift::protoco
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size176;
- ::apache::thrift::protocol::TType _etype179;
- xfer += iprot->readListBegin(_etype179, _size176);
- (*(this->success)).resize(_size176);
- uint32_t _i180;
- for (_i180 = 0; _i180 < _size176; ++_i180)
+ uint32_t _size191;
+ ::apache::thrift::protocol::TType _etype194;
+ xfer += iprot->readListBegin(_etype194, _size191);
+ (*(this->success)).resize(_size191);
+ uint32_t _i195;
+ for (_i195 = 0; _i195 < _size191; ++_i195)
{
- xfer += (*(this->success))[_i180].read(iprot);
+ xfer += (*(this->success))[_i195].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9450,14 +10183,14 @@ uint32_t Airavata_getAllAppModules_result::read(::apache::thrift::protocol::TPro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size181;
- ::apache::thrift::protocol::TType _etype184;
- xfer += iprot->readListBegin(_etype184, _size181);
- this->success.resize(_size181);
- uint32_t _i185;
- for (_i185 = 0; _i185 < _size181; ++_i185)
+ uint32_t _size196;
+ ::apache::thrift::protocol::TType _etype199;
+ xfer += iprot->readListBegin(_etype199, _size196);
+ this->success.resize(_size196);
+ uint32_t _i200;
+ for (_i200 = 0; _i200 < _size196; ++_i200)
{
- xfer += this->success[_i185].read(iprot);
+ xfer += this->success[_i200].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9512,10 +10245,10 @@ uint32_t Airavata_getAllAppModules_result::write(::apache::thrift::protocol::TPr
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationModule> ::const_iterator _iter186;
- for (_iter186 = this->success.begin(); _iter186 != this->success.end(); ++_iter186)
+ std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationModule> ::const_iterator _iter201;
+ for (_iter201 = this->success.begin(); _iter201 != this->success.end(); ++_iter201)
{
- xfer += (*_iter186).write(oprot);
+ xfer += (*_iter201).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9562,14 +10295,14 @@ uint32_t Airavata_getAllAppModules_presult::read(::apache::thrift::protocol::TPr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size187;
- ::apache::thrift::protocol::TType _etype190;
- xfer += iprot->readListBegin(_etype190, _size187);
- (*(this->success)).resize(_size187);
- uint32_t _i191;
- for (_i191 = 0; _i191 < _size187; ++_i191)
+ uint32_t _size202;
+ ::apache::thrift::protocol::TType _etype205;
+ xfer += iprot->readListBegin(_etype205, _size202);
+ (*(this->success)).resize(_size202);
+ uint32_t _i206;
+ for (_i206 = 0; _i206 < _size202; ++_i206)
{
- xfer += (*(this->success))[_i191].read(iprot);
+ xfer += (*(this->success))[_i206].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -10827,14 +11560,14 @@ uint32_t Airavata_getAllApplicationDeployments_result::read(::apache::thrift::pr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size192;
- ::apache::thrift::protocol::TType _etype195;
- xfer += iprot->readListBegin(_etype195, _size192);
- this->success.resize(_size192);
- uint32_t _i196;
- for (_i196 = 0; _i196 < _size192; ++_i196)
+ uint32_t _size207;
+ ::apache::thrift::protocol::TType _etype210;
+ xfer += iprot->readListBegin(_etype210, _size207);
+ this->success.resize(_size207);
+ uint32_t _i211;
+ for (_i211 = 0; _i211 < _size207; ++_i211)
{
- xfer += this->success[_i196].read(iprot);
+ xfer += this->success[_i211].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -10889,10 +11622,10 @@ uint32_t Airavata_getAllApplicationDeployments_result::write(::apache::thrift::p
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationDeploymentDescription> ::const_iterator _iter197;
- for (_iter197 = this->success.begin(); _iter197 != this->success.end(); ++_iter197)
+ std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationDeploymentDescription> ::const_iterator _iter212;
+ for (_iter212 = this->success.begin(); _iter212 != this->success.end(); ++_iter212)
{
- xfer += (*_iter197).write(oprot);
+ xfer += (*_iter212).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -10939,14 +11672,14 @@ uint32_t Airavata_getAllApplicationDeployments_presult::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size198;
- ::apache::thrift::protocol::TType _etype201;
- xfer += iprot->readListBegin(_etype201, _size198);
- (*(this->success)).resize(_size198);
- uint32_t _i202;
- for (_i202 = 0; _i202 < _size198; ++_i202)
+ uint32_t _size213;
+ ::apache::thrift::protocol::TType _etype216;
+ xfer += iprot->readListBegin(_etype216, _size213);
+ (*(this->success)).resize(_size213);
+ uint32_t _i217;
+ for (_i217 = 0; _i217 < _size213; ++_i217)
{
- xfer += (*(this->success))[_i202].read(iprot);
+ xfer += (*(this->success))[_i217].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -11084,14 +11817,14 @@ uint32_t Airavata_getAppModuleDeployedResources_result::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size203;
- ::apache::thrift::protocol::TType _etype206;
- xfer += iprot->readListBegin(_etype206, _size203);
- this->success.resize(_size203);
- uint32_t _i207;
- for (_i207 = 0; _i207 < _size203; ++_i207)
+ uint32_t _size218;
+ ::apache::thrift::protocol::TType _etype221;
+ xfer += iprot->readListBegin(_etype221, _size218);
+ this->success.resize(_size218);
+ uint32_t _i222;
+ for (_i222 = 0; _i222 < _size218; ++_i222)
{
- xfer += iprot->readString(this->success[_i207]);
+ xfer += iprot->readString(this->success[_i222]);
}
xfer += iprot->readListEnd();
}
@@ -11146,10 +11879,10 @@ uint32_t Airavata_getAppModuleDeployedResources_result::write(::apache::thrift::
xfer += oprot->writeFieldBegin("
<TRUNCATED>