Return-Path: X-Original-To: apmail-airavata-commits-archive@www.apache.org Delivered-To: apmail-airavata-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8D54510023 for ; Sun, 9 Feb 2014 03:14:24 +0000 (UTC) Received: (qmail 61562 invoked by uid 500); 9 Feb 2014 03:14:22 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 61458 invoked by uid 500); 9 Feb 2014 03:14:19 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 61396 invoked by uid 99); 9 Feb 2014 03:14:18 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 09 Feb 2014 03:14:18 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 7D4C6920E29; Sun, 9 Feb 2014 03:14:17 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: smarru@apache.org To: commits@airavata.apache.org Date: Sun, 09 Feb 2014 03:14:20 -0000 Message-Id: <95a2ee94b8184034b7fef885bdb815b4@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [05/16] adding generated code for API AIRAVATA-991 http://git-wip-us.apache.org/repos/asf/airavata/blob/28ac4b75/airavata-api/server/src/main/java/org/apache/airavata/api/error/InvalidRequestException.java ---------------------------------------------------------------------- diff --git a/airavata-api/server/src/main/java/org/apache/airavata/api/error/InvalidRequestException.java b/airavata-api/server/src/main/java/org/apache/airavata/api/error/InvalidRequestException.java new file mode 100644 index 0000000..a0572d3 --- /dev/null +++ b/airavata-api/server/src/main/java/org/apache/airavata/api/error/InvalidRequestException.java @@ -0,0 +1,403 @@ + /* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/** + * Autogenerated by Thrift Compiler (0.9.1) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.airavata.api.error; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * This exception is thrown for invalid requests that occur from any reasons like required input parameters are missing, + * or a parameter is malformed. + * + * message: contains the associated error message. + */ +@SuppressWarnings("all") public class InvalidRequestException extends TException implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("InvalidRequestException"); + + private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new InvalidRequestExceptionStandardSchemeFactory()); + schemes.put(TupleScheme.class, new InvalidRequestExceptionTupleSchemeFactory()); + } + + public String message; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + MESSAGE((short)1, "message"); + + private static final Map byName = new HashMap(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // MESSAGE + return MESSAGE; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + 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); + tmpMap.put(_Fields.MESSAGE, new org.apache.thrift.meta_data.FieldMetaData("message", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(InvalidRequestException.class, metaDataMap); + } + + public InvalidRequestException() { + } + + public InvalidRequestException( + String message) + { + this(); + this.message = message; + } + + /** + * Performs a deep copy on other. + */ + public InvalidRequestException(InvalidRequestException other) { + if (other.isSetMessage()) { + this.message = other.message; + } + } + + public InvalidRequestException deepCopy() { + return new InvalidRequestException(this); + } + + @Override + public void clear() { + this.message = null; + } + + public String getMessage() { + return this.message; + } + + public InvalidRequestException setMessage(String message) { + this.message = message; + return this; + } + + public void unsetMessage() { + this.message = null; + } + + /** Returns true if field message is set (has been assigned a value) and false otherwise */ + public boolean isSetMessage() { + return this.message != null; + } + + public void setMessageIsSet(boolean value) { + if (!value) { + this.message = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case MESSAGE: + if (value == null) { + unsetMessage(); + } else { + setMessage((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case MESSAGE: + return getMessage(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case MESSAGE: + return isSetMessage(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof InvalidRequestException) + return this.equals((InvalidRequestException)that); + return false; + } + + public boolean equals(InvalidRequestException that) { + if (that == null) + return false; + + boolean this_present_message = true && this.isSetMessage(); + boolean that_present_message = true && that.isSetMessage(); + if (this_present_message || that_present_message) { + if (!(this_present_message && that_present_message)) + return false; + if (!this.message.equals(that.message)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + @Override + public int compareTo(InvalidRequestException other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetMessage()).compareTo(other.isSetMessage()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetMessage()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.message, other.message); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("InvalidRequestException("); + boolean first = true; + + sb.append("message:"); + if (this.message == null) { + sb.append("null"); + } else { + sb.append(this.message); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (message == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'message' was not present! Struct: " + toString()); + } + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class InvalidRequestExceptionStandardSchemeFactory implements SchemeFactory { + public InvalidRequestExceptionStandardScheme getScheme() { + return new InvalidRequestExceptionStandardScheme(); + } + } + + private static class InvalidRequestExceptionStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, InvalidRequestException struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // MESSAGE + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.message = iprot.readString(); + struct.setMessageIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, InvalidRequestException struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.message != null) { + oprot.writeFieldBegin(MESSAGE_FIELD_DESC); + oprot.writeString(struct.message); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class InvalidRequestExceptionTupleSchemeFactory implements SchemeFactory { + public InvalidRequestExceptionTupleScheme getScheme() { + return new InvalidRequestExceptionTupleScheme(); + } + } + + private static class InvalidRequestExceptionTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, InvalidRequestException struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.message); + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, InvalidRequestException struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.message = iprot.readString(); + struct.setMessageIsSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/airavata/blob/28ac4b75/airavata-api/server/src/main/java/org/apache/airavata/api/error/TimedOutException.java ---------------------------------------------------------------------- diff --git a/airavata-api/server/src/main/java/org/apache/airavata/api/error/TimedOutException.java b/airavata-api/server/src/main/java/org/apache/airavata/api/error/TimedOutException.java new file mode 100644 index 0000000..a746de0 --- /dev/null +++ b/airavata-api/server/src/main/java/org/apache/airavata/api/error/TimedOutException.java @@ -0,0 +1,299 @@ + /* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/** + * Autogenerated by Thrift Compiler (0.9.1) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.airavata.api.error; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * This exception is thrown when RPC timeout gets exceeded. + */ +@SuppressWarnings("all") public class TimedOutException extends TException implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TimedOutException"); + + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new TimedOutExceptionStandardSchemeFactory()); + schemes.put(TupleScheme.class, new TimedOutExceptionTupleSchemeFactory()); + } + + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { +; + + private static final Map byName = new HashMap(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + 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); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TimedOutException.class, metaDataMap); + } + + public TimedOutException() { + } + + /** + * Performs a deep copy on other. + */ + public TimedOutException(TimedOutException other) { + } + + public TimedOutException deepCopy() { + return new TimedOutException(this); + } + + @Override + public void clear() { + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof TimedOutException) + return this.equals((TimedOutException)that); + return false; + } + + public boolean equals(TimedOutException that) { + if (that == null) + return false; + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + @Override + public int compareTo(TimedOutException other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("TimedOutException("); + boolean first = true; + + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class TimedOutExceptionStandardSchemeFactory implements SchemeFactory { + public TimedOutExceptionStandardScheme getScheme() { + return new TimedOutExceptionStandardScheme(); + } + } + + private static class TimedOutExceptionStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, TimedOutException struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, TimedOutException struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class TimedOutExceptionTupleSchemeFactory implements SchemeFactory { + public TimedOutExceptionTupleScheme getScheme() { + return new TimedOutExceptionTupleScheme(); + } + } + + private static class TimedOutExceptionTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, TimedOutException struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, TimedOutException struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + } + } + +} + http://git-wip-us.apache.org/repos/asf/airavata/blob/28ac4b75/airavata-api/server/src/main/java/org/apache/airavata/model/experiment/AdvancedInputDataHandling.java ---------------------------------------------------------------------- diff --git a/airavata-api/server/src/main/java/org/apache/airavata/model/experiment/AdvancedInputDataHandling.java b/airavata-api/server/src/main/java/org/apache/airavata/model/experiment/AdvancedInputDataHandling.java new file mode 100644 index 0000000..4cf5045 --- /dev/null +++ b/airavata-api/server/src/main/java/org/apache/airavata/model/experiment/AdvancedInputDataHandling.java @@ -0,0 +1,706 @@ + /* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/** + * Autogenerated by Thrift Compiler (0.9.1) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.airavata.model.experiment; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * A structure holding specified input data handling. + * + */ +@SuppressWarnings("all") public class AdvancedInputDataHandling implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AdvancedInputDataHandling"); + + private static final org.apache.thrift.protocol.TField STAGE_INPUT_FILES_TO_WORKING_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("stageInputFilesToWorkingDir", org.apache.thrift.protocol.TType.BOOL, (short)1); + private static final org.apache.thrift.protocol.TField WORKING_DIRECTORY_PARENT_FIELD_DESC = new org.apache.thrift.protocol.TField("workingDirectoryParent", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField UNIQUE_WORKING_DIRECTORY_FIELD_DESC = new org.apache.thrift.protocol.TField("uniqueWorkingDirectory", org.apache.thrift.protocol.TType.STRING, (short)3); + private static final org.apache.thrift.protocol.TField CLEAN_UP_WORKING_DIR_AFTER_JOB_FIELD_DESC = new org.apache.thrift.protocol.TField("cleanUpWorkingDirAfterJob", org.apache.thrift.protocol.TType.BOOL, (short)4); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new AdvancedInputDataHandlingStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AdvancedInputDataHandlingTupleSchemeFactory()); + } + + public boolean stageInputFilesToWorkingDir; // optional + public String workingDirectoryParent; // optional + public String uniqueWorkingDirectory; // optional + public boolean cleanUpWorkingDirAfterJob; // optional + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + STAGE_INPUT_FILES_TO_WORKING_DIR((short)1, "stageInputFilesToWorkingDir"), + WORKING_DIRECTORY_PARENT((short)2, "workingDirectoryParent"), + UNIQUE_WORKING_DIRECTORY((short)3, "uniqueWorkingDirectory"), + CLEAN_UP_WORKING_DIR_AFTER_JOB((short)4, "cleanUpWorkingDirAfterJob"); + + private static final Map byName = new HashMap(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // STAGE_INPUT_FILES_TO_WORKING_DIR + return STAGE_INPUT_FILES_TO_WORKING_DIR; + case 2: // WORKING_DIRECTORY_PARENT + return WORKING_DIRECTORY_PARENT; + case 3: // UNIQUE_WORKING_DIRECTORY + return UNIQUE_WORKING_DIRECTORY; + case 4: // CLEAN_UP_WORKING_DIR_AFTER_JOB + return CLEAN_UP_WORKING_DIR_AFTER_JOB; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + private static final int __STAGEINPUTFILESTOWORKINGDIR_ISSET_ID = 0; + private static final int __CLEANUPWORKINGDIRAFTERJOB_ISSET_ID = 1; + private byte __isset_bitfield = 0; + private _Fields optionals[] = {_Fields.STAGE_INPUT_FILES_TO_WORKING_DIR,_Fields.WORKING_DIRECTORY_PARENT,_Fields.UNIQUE_WORKING_DIRECTORY,_Fields.CLEAN_UP_WORKING_DIR_AFTER_JOB}; + 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); + tmpMap.put(_Fields.STAGE_INPUT_FILES_TO_WORKING_DIR, new org.apache.thrift.meta_data.FieldMetaData("stageInputFilesToWorkingDir", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); + tmpMap.put(_Fields.WORKING_DIRECTORY_PARENT, new org.apache.thrift.meta_data.FieldMetaData("workingDirectoryParent", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.UNIQUE_WORKING_DIRECTORY, new org.apache.thrift.meta_data.FieldMetaData("uniqueWorkingDirectory", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.CLEAN_UP_WORKING_DIR_AFTER_JOB, new org.apache.thrift.meta_data.FieldMetaData("cleanUpWorkingDirAfterJob", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AdvancedInputDataHandling.class, metaDataMap); + } + + public AdvancedInputDataHandling() { + this.stageInputFilesToWorkingDir = false; + + this.cleanUpWorkingDirAfterJob = false; + + } + + /** + * Performs a deep copy on other. + */ + public AdvancedInputDataHandling(AdvancedInputDataHandling other) { + __isset_bitfield = other.__isset_bitfield; + this.stageInputFilesToWorkingDir = other.stageInputFilesToWorkingDir; + if (other.isSetWorkingDirectoryParent()) { + this.workingDirectoryParent = other.workingDirectoryParent; + } + if (other.isSetUniqueWorkingDirectory()) { + this.uniqueWorkingDirectory = other.uniqueWorkingDirectory; + } + this.cleanUpWorkingDirAfterJob = other.cleanUpWorkingDirAfterJob; + } + + public AdvancedInputDataHandling deepCopy() { + return new AdvancedInputDataHandling(this); + } + + @Override + public void clear() { + this.stageInputFilesToWorkingDir = false; + + this.workingDirectoryParent = null; + this.uniqueWorkingDirectory = null; + this.cleanUpWorkingDirAfterJob = false; + + } + + public boolean isStageInputFilesToWorkingDir() { + return this.stageInputFilesToWorkingDir; + } + + public AdvancedInputDataHandling setStageInputFilesToWorkingDir(boolean stageInputFilesToWorkingDir) { + this.stageInputFilesToWorkingDir = stageInputFilesToWorkingDir; + setStageInputFilesToWorkingDirIsSet(true); + return this; + } + + public void unsetStageInputFilesToWorkingDir() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __STAGEINPUTFILESTOWORKINGDIR_ISSET_ID); + } + + /** Returns true if field stageInputFilesToWorkingDir is set (has been assigned a value) and false otherwise */ + public boolean isSetStageInputFilesToWorkingDir() { + return EncodingUtils.testBit(__isset_bitfield, __STAGEINPUTFILESTOWORKINGDIR_ISSET_ID); + } + + public void setStageInputFilesToWorkingDirIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __STAGEINPUTFILESTOWORKINGDIR_ISSET_ID, value); + } + + public String getWorkingDirectoryParent() { + return this.workingDirectoryParent; + } + + public AdvancedInputDataHandling setWorkingDirectoryParent(String workingDirectoryParent) { + this.workingDirectoryParent = workingDirectoryParent; + return this; + } + + public void unsetWorkingDirectoryParent() { + this.workingDirectoryParent = null; + } + + /** Returns true if field workingDirectoryParent is set (has been assigned a value) and false otherwise */ + public boolean isSetWorkingDirectoryParent() { + return this.workingDirectoryParent != null; + } + + public void setWorkingDirectoryParentIsSet(boolean value) { + if (!value) { + this.workingDirectoryParent = null; + } + } + + public String getUniqueWorkingDirectory() { + return this.uniqueWorkingDirectory; + } + + public AdvancedInputDataHandling setUniqueWorkingDirectory(String uniqueWorkingDirectory) { + this.uniqueWorkingDirectory = uniqueWorkingDirectory; + return this; + } + + public void unsetUniqueWorkingDirectory() { + this.uniqueWorkingDirectory = null; + } + + /** Returns true if field uniqueWorkingDirectory is set (has been assigned a value) and false otherwise */ + public boolean isSetUniqueWorkingDirectory() { + return this.uniqueWorkingDirectory != null; + } + + public void setUniqueWorkingDirectoryIsSet(boolean value) { + if (!value) { + this.uniqueWorkingDirectory = null; + } + } + + public boolean isCleanUpWorkingDirAfterJob() { + return this.cleanUpWorkingDirAfterJob; + } + + public AdvancedInputDataHandling setCleanUpWorkingDirAfterJob(boolean cleanUpWorkingDirAfterJob) { + this.cleanUpWorkingDirAfterJob = cleanUpWorkingDirAfterJob; + setCleanUpWorkingDirAfterJobIsSet(true); + return this; + } + + public void unsetCleanUpWorkingDirAfterJob() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CLEANUPWORKINGDIRAFTERJOB_ISSET_ID); + } + + /** Returns true if field cleanUpWorkingDirAfterJob is set (has been assigned a value) and false otherwise */ + public boolean isSetCleanUpWorkingDirAfterJob() { + return EncodingUtils.testBit(__isset_bitfield, __CLEANUPWORKINGDIRAFTERJOB_ISSET_ID); + } + + public void setCleanUpWorkingDirAfterJobIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CLEANUPWORKINGDIRAFTERJOB_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case STAGE_INPUT_FILES_TO_WORKING_DIR: + if (value == null) { + unsetStageInputFilesToWorkingDir(); + } else { + setStageInputFilesToWorkingDir((Boolean)value); + } + break; + + case WORKING_DIRECTORY_PARENT: + if (value == null) { + unsetWorkingDirectoryParent(); + } else { + setWorkingDirectoryParent((String)value); + } + break; + + case UNIQUE_WORKING_DIRECTORY: + if (value == null) { + unsetUniqueWorkingDirectory(); + } else { + setUniqueWorkingDirectory((String)value); + } + break; + + case CLEAN_UP_WORKING_DIR_AFTER_JOB: + if (value == null) { + unsetCleanUpWorkingDirAfterJob(); + } else { + setCleanUpWorkingDirAfterJob((Boolean)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case STAGE_INPUT_FILES_TO_WORKING_DIR: + return Boolean.valueOf(isStageInputFilesToWorkingDir()); + + case WORKING_DIRECTORY_PARENT: + return getWorkingDirectoryParent(); + + case UNIQUE_WORKING_DIRECTORY: + return getUniqueWorkingDirectory(); + + case CLEAN_UP_WORKING_DIR_AFTER_JOB: + return Boolean.valueOf(isCleanUpWorkingDirAfterJob()); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case STAGE_INPUT_FILES_TO_WORKING_DIR: + return isSetStageInputFilesToWorkingDir(); + case WORKING_DIRECTORY_PARENT: + return isSetWorkingDirectoryParent(); + case UNIQUE_WORKING_DIRECTORY: + return isSetUniqueWorkingDirectory(); + case CLEAN_UP_WORKING_DIR_AFTER_JOB: + return isSetCleanUpWorkingDirAfterJob(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AdvancedInputDataHandling) + return this.equals((AdvancedInputDataHandling)that); + return false; + } + + public boolean equals(AdvancedInputDataHandling that) { + if (that == null) + return false; + + boolean this_present_stageInputFilesToWorkingDir = true && this.isSetStageInputFilesToWorkingDir(); + boolean that_present_stageInputFilesToWorkingDir = true && that.isSetStageInputFilesToWorkingDir(); + if (this_present_stageInputFilesToWorkingDir || that_present_stageInputFilesToWorkingDir) { + if (!(this_present_stageInputFilesToWorkingDir && that_present_stageInputFilesToWorkingDir)) + return false; + if (this.stageInputFilesToWorkingDir != that.stageInputFilesToWorkingDir) + return false; + } + + boolean this_present_workingDirectoryParent = true && this.isSetWorkingDirectoryParent(); + boolean that_present_workingDirectoryParent = true && that.isSetWorkingDirectoryParent(); + if (this_present_workingDirectoryParent || that_present_workingDirectoryParent) { + if (!(this_present_workingDirectoryParent && that_present_workingDirectoryParent)) + return false; + if (!this.workingDirectoryParent.equals(that.workingDirectoryParent)) + return false; + } + + boolean this_present_uniqueWorkingDirectory = true && this.isSetUniqueWorkingDirectory(); + boolean that_present_uniqueWorkingDirectory = true && that.isSetUniqueWorkingDirectory(); + if (this_present_uniqueWorkingDirectory || that_present_uniqueWorkingDirectory) { + if (!(this_present_uniqueWorkingDirectory && that_present_uniqueWorkingDirectory)) + return false; + if (!this.uniqueWorkingDirectory.equals(that.uniqueWorkingDirectory)) + return false; + } + + boolean this_present_cleanUpWorkingDirAfterJob = true && this.isSetCleanUpWorkingDirAfterJob(); + boolean that_present_cleanUpWorkingDirAfterJob = true && that.isSetCleanUpWorkingDirAfterJob(); + if (this_present_cleanUpWorkingDirAfterJob || that_present_cleanUpWorkingDirAfterJob) { + if (!(this_present_cleanUpWorkingDirAfterJob && that_present_cleanUpWorkingDirAfterJob)) + return false; + if (this.cleanUpWorkingDirAfterJob != that.cleanUpWorkingDirAfterJob) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + @Override + public int compareTo(AdvancedInputDataHandling other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetStageInputFilesToWorkingDir()).compareTo(other.isSetStageInputFilesToWorkingDir()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetStageInputFilesToWorkingDir()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.stageInputFilesToWorkingDir, other.stageInputFilesToWorkingDir); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetWorkingDirectoryParent()).compareTo(other.isSetWorkingDirectoryParent()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetWorkingDirectoryParent()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.workingDirectoryParent, other.workingDirectoryParent); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetUniqueWorkingDirectory()).compareTo(other.isSetUniqueWorkingDirectory()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetUniqueWorkingDirectory()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uniqueWorkingDirectory, other.uniqueWorkingDirectory); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetCleanUpWorkingDirAfterJob()).compareTo(other.isSetCleanUpWorkingDirAfterJob()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCleanUpWorkingDirAfterJob()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.cleanUpWorkingDirAfterJob, other.cleanUpWorkingDirAfterJob); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("AdvancedInputDataHandling("); + boolean first = true; + + if (isSetStageInputFilesToWorkingDir()) { + sb.append("stageInputFilesToWorkingDir:"); + sb.append(this.stageInputFilesToWorkingDir); + first = false; + } + if (isSetWorkingDirectoryParent()) { + if (!first) sb.append(", "); + sb.append("workingDirectoryParent:"); + if (this.workingDirectoryParent == null) { + sb.append("null"); + } else { + sb.append(this.workingDirectoryParent); + } + first = false; + } + if (isSetUniqueWorkingDirectory()) { + if (!first) sb.append(", "); + sb.append("uniqueWorkingDirectory:"); + if (this.uniqueWorkingDirectory == null) { + sb.append("null"); + } else { + sb.append(this.uniqueWorkingDirectory); + } + first = false; + } + if (isSetCleanUpWorkingDirAfterJob()) { + if (!first) sb.append(", "); + sb.append("cleanUpWorkingDirAfterJob:"); + sb.append(this.cleanUpWorkingDirAfterJob); + first = false; + } + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. + __isset_bitfield = 0; + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class AdvancedInputDataHandlingStandardSchemeFactory implements SchemeFactory { + public AdvancedInputDataHandlingStandardScheme getScheme() { + return new AdvancedInputDataHandlingStandardScheme(); + } + } + + private static class AdvancedInputDataHandlingStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, AdvancedInputDataHandling struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // STAGE_INPUT_FILES_TO_WORKING_DIR + if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { + struct.stageInputFilesToWorkingDir = iprot.readBool(); + struct.setStageInputFilesToWorkingDirIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // WORKING_DIRECTORY_PARENT + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.workingDirectoryParent = iprot.readString(); + struct.setWorkingDirectoryParentIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // UNIQUE_WORKING_DIRECTORY + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.uniqueWorkingDirectory = iprot.readString(); + struct.setUniqueWorkingDirectoryIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // CLEAN_UP_WORKING_DIR_AFTER_JOB + if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { + struct.cleanUpWorkingDirAfterJob = iprot.readBool(); + struct.setCleanUpWorkingDirAfterJobIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, AdvancedInputDataHandling struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.isSetStageInputFilesToWorkingDir()) { + oprot.writeFieldBegin(STAGE_INPUT_FILES_TO_WORKING_DIR_FIELD_DESC); + oprot.writeBool(struct.stageInputFilesToWorkingDir); + oprot.writeFieldEnd(); + } + if (struct.workingDirectoryParent != null) { + if (struct.isSetWorkingDirectoryParent()) { + oprot.writeFieldBegin(WORKING_DIRECTORY_PARENT_FIELD_DESC); + oprot.writeString(struct.workingDirectoryParent); + oprot.writeFieldEnd(); + } + } + if (struct.uniqueWorkingDirectory != null) { + if (struct.isSetUniqueWorkingDirectory()) { + oprot.writeFieldBegin(UNIQUE_WORKING_DIRECTORY_FIELD_DESC); + oprot.writeString(struct.uniqueWorkingDirectory); + oprot.writeFieldEnd(); + } + } + if (struct.isSetCleanUpWorkingDirAfterJob()) { + oprot.writeFieldBegin(CLEAN_UP_WORKING_DIR_AFTER_JOB_FIELD_DESC); + oprot.writeBool(struct.cleanUpWorkingDirAfterJob); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AdvancedInputDataHandlingTupleSchemeFactory implements SchemeFactory { + public AdvancedInputDataHandlingTupleScheme getScheme() { + return new AdvancedInputDataHandlingTupleScheme(); + } + } + + private static class AdvancedInputDataHandlingTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, AdvancedInputDataHandling struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetStageInputFilesToWorkingDir()) { + optionals.set(0); + } + if (struct.isSetWorkingDirectoryParent()) { + optionals.set(1); + } + if (struct.isSetUniqueWorkingDirectory()) { + optionals.set(2); + } + if (struct.isSetCleanUpWorkingDirAfterJob()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); + if (struct.isSetStageInputFilesToWorkingDir()) { + oprot.writeBool(struct.stageInputFilesToWorkingDir); + } + if (struct.isSetWorkingDirectoryParent()) { + oprot.writeString(struct.workingDirectoryParent); + } + if (struct.isSetUniqueWorkingDirectory()) { + oprot.writeString(struct.uniqueWorkingDirectory); + } + if (struct.isSetCleanUpWorkingDirAfterJob()) { + oprot.writeBool(struct.cleanUpWorkingDirAfterJob); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, AdvancedInputDataHandling struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(4); + if (incoming.get(0)) { + struct.stageInputFilesToWorkingDir = iprot.readBool(); + struct.setStageInputFilesToWorkingDirIsSet(true); + } + if (incoming.get(1)) { + struct.workingDirectoryParent = iprot.readString(); + struct.setWorkingDirectoryParentIsSet(true); + } + if (incoming.get(2)) { + struct.uniqueWorkingDirectory = iprot.readString(); + struct.setUniqueWorkingDirectoryIsSet(true); + } + if (incoming.get(3)) { + struct.cleanUpWorkingDirAfterJob = iprot.readBool(); + struct.setCleanUpWorkingDirAfterJobIsSet(true); + } + } + } + +} + http://git-wip-us.apache.org/repos/asf/airavata/blob/28ac4b75/airavata-api/server/src/main/java/org/apache/airavata/model/experiment/AdvancedOutputDataHandling.java ---------------------------------------------------------------------- diff --git a/airavata-api/server/src/main/java/org/apache/airavata/model/experiment/AdvancedOutputDataHandling.java b/airavata-api/server/src/main/java/org/apache/airavata/model/experiment/AdvancedOutputDataHandling.java new file mode 100644 index 0000000..7bec30e --- /dev/null +++ b/airavata-api/server/src/main/java/org/apache/airavata/model/experiment/AdvancedOutputDataHandling.java @@ -0,0 +1,609 @@ + /* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/** + * Autogenerated by Thrift Compiler (0.9.1) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.airavata.model.experiment; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * A structure holding specified output data handling. + * + */ +@SuppressWarnings("all") public class AdvancedOutputDataHandling implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AdvancedOutputDataHandling"); + + private static final org.apache.thrift.protocol.TField OUTPUTDATA_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("outputdataDir", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField DATA_REGISTRY_URL_FIELD_DESC = new org.apache.thrift.protocol.TField("dataRegistryURL", org.apache.thrift.protocol.TType.STRING, (short)3); + private static final org.apache.thrift.protocol.TField PERSIST_OUTPUT_DATA_FIELD_DESC = new org.apache.thrift.protocol.TField("persistOutputData", org.apache.thrift.protocol.TType.BOOL, (short)4); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new AdvancedOutputDataHandlingStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AdvancedOutputDataHandlingTupleSchemeFactory()); + } + + public String outputdataDir; // optional + public String dataRegistryURL; // optional + public boolean persistOutputData; // optional + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + OUTPUTDATA_DIR((short)2, "outputdataDir"), + DATA_REGISTRY_URL((short)3, "dataRegistryURL"), + PERSIST_OUTPUT_DATA((short)4, "persistOutputData"); + + private static final Map byName = new HashMap(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 2: // OUTPUTDATA_DIR + return OUTPUTDATA_DIR; + case 3: // DATA_REGISTRY_URL + return DATA_REGISTRY_URL; + case 4: // PERSIST_OUTPUT_DATA + return PERSIST_OUTPUT_DATA; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + private static final int __PERSISTOUTPUTDATA_ISSET_ID = 0; + private byte __isset_bitfield = 0; + private _Fields optionals[] = {_Fields.OUTPUTDATA_DIR,_Fields.DATA_REGISTRY_URL,_Fields.PERSIST_OUTPUT_DATA}; + 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); + tmpMap.put(_Fields.OUTPUTDATA_DIR, new org.apache.thrift.meta_data.FieldMetaData("outputdataDir", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.DATA_REGISTRY_URL, new org.apache.thrift.meta_data.FieldMetaData("dataRegistryURL", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.PERSIST_OUTPUT_DATA, new org.apache.thrift.meta_data.FieldMetaData("persistOutputData", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AdvancedOutputDataHandling.class, metaDataMap); + } + + public AdvancedOutputDataHandling() { + this.persistOutputData = true; + + } + + /** + * Performs a deep copy on other. + */ + public AdvancedOutputDataHandling(AdvancedOutputDataHandling other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetOutputdataDir()) { + this.outputdataDir = other.outputdataDir; + } + if (other.isSetDataRegistryURL()) { + this.dataRegistryURL = other.dataRegistryURL; + } + this.persistOutputData = other.persistOutputData; + } + + public AdvancedOutputDataHandling deepCopy() { + return new AdvancedOutputDataHandling(this); + } + + @Override + public void clear() { + this.outputdataDir = null; + this.dataRegistryURL = null; + this.persistOutputData = true; + + } + + public String getOutputdataDir() { + return this.outputdataDir; + } + + public AdvancedOutputDataHandling setOutputdataDir(String outputdataDir) { + this.outputdataDir = outputdataDir; + return this; + } + + public void unsetOutputdataDir() { + this.outputdataDir = null; + } + + /** Returns true if field outputdataDir is set (has been assigned a value) and false otherwise */ + public boolean isSetOutputdataDir() { + return this.outputdataDir != null; + } + + public void setOutputdataDirIsSet(boolean value) { + if (!value) { + this.outputdataDir = null; + } + } + + public String getDataRegistryURL() { + return this.dataRegistryURL; + } + + public AdvancedOutputDataHandling setDataRegistryURL(String dataRegistryURL) { + this.dataRegistryURL = dataRegistryURL; + return this; + } + + public void unsetDataRegistryURL() { + this.dataRegistryURL = null; + } + + /** Returns true if field dataRegistryURL is set (has been assigned a value) and false otherwise */ + public boolean isSetDataRegistryURL() { + return this.dataRegistryURL != null; + } + + public void setDataRegistryURLIsSet(boolean value) { + if (!value) { + this.dataRegistryURL = null; + } + } + + public boolean isPersistOutputData() { + return this.persistOutputData; + } + + public AdvancedOutputDataHandling setPersistOutputData(boolean persistOutputData) { + this.persistOutputData = persistOutputData; + setPersistOutputDataIsSet(true); + return this; + } + + public void unsetPersistOutputData() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PERSISTOUTPUTDATA_ISSET_ID); + } + + /** Returns true if field persistOutputData is set (has been assigned a value) and false otherwise */ + public boolean isSetPersistOutputData() { + return EncodingUtils.testBit(__isset_bitfield, __PERSISTOUTPUTDATA_ISSET_ID); + } + + public void setPersistOutputDataIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PERSISTOUTPUTDATA_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case OUTPUTDATA_DIR: + if (value == null) { + unsetOutputdataDir(); + } else { + setOutputdataDir((String)value); + } + break; + + case DATA_REGISTRY_URL: + if (value == null) { + unsetDataRegistryURL(); + } else { + setDataRegistryURL((String)value); + } + break; + + case PERSIST_OUTPUT_DATA: + if (value == null) { + unsetPersistOutputData(); + } else { + setPersistOutputData((Boolean)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case OUTPUTDATA_DIR: + return getOutputdataDir(); + + case DATA_REGISTRY_URL: + return getDataRegistryURL(); + + case PERSIST_OUTPUT_DATA: + return Boolean.valueOf(isPersistOutputData()); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case OUTPUTDATA_DIR: + return isSetOutputdataDir(); + case DATA_REGISTRY_URL: + return isSetDataRegistryURL(); + case PERSIST_OUTPUT_DATA: + return isSetPersistOutputData(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AdvancedOutputDataHandling) + return this.equals((AdvancedOutputDataHandling)that); + return false; + } + + public boolean equals(AdvancedOutputDataHandling that) { + if (that == null) + return false; + + boolean this_present_outputdataDir = true && this.isSetOutputdataDir(); + boolean that_present_outputdataDir = true && that.isSetOutputdataDir(); + if (this_present_outputdataDir || that_present_outputdataDir) { + if (!(this_present_outputdataDir && that_present_outputdataDir)) + return false; + if (!this.outputdataDir.equals(that.outputdataDir)) + return false; + } + + boolean this_present_dataRegistryURL = true && this.isSetDataRegistryURL(); + boolean that_present_dataRegistryURL = true && that.isSetDataRegistryURL(); + if (this_present_dataRegistryURL || that_present_dataRegistryURL) { + if (!(this_present_dataRegistryURL && that_present_dataRegistryURL)) + return false; + if (!this.dataRegistryURL.equals(that.dataRegistryURL)) + return false; + } + + boolean this_present_persistOutputData = true && this.isSetPersistOutputData(); + boolean that_present_persistOutputData = true && that.isSetPersistOutputData(); + if (this_present_persistOutputData || that_present_persistOutputData) { + if (!(this_present_persistOutputData && that_present_persistOutputData)) + return false; + if (this.persistOutputData != that.persistOutputData) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + @Override + public int compareTo(AdvancedOutputDataHandling other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetOutputdataDir()).compareTo(other.isSetOutputdataDir()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetOutputdataDir()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.outputdataDir, other.outputdataDir); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetDataRegistryURL()).compareTo(other.isSetDataRegistryURL()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDataRegistryURL()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dataRegistryURL, other.dataRegistryURL); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetPersistOutputData()).compareTo(other.isSetPersistOutputData()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPersistOutputData()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.persistOutputData, other.persistOutputData); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("AdvancedOutputDataHandling("); + boolean first = true; + + if (isSetOutputdataDir()) { + sb.append("outputdataDir:"); + if (this.outputdataDir == null) { + sb.append("null"); + } else { + sb.append(this.outputdataDir); + } + first = false; + } + if (isSetDataRegistryURL()) { + if (!first) sb.append(", "); + sb.append("dataRegistryURL:"); + if (this.dataRegistryURL == null) { + sb.append("null"); + } else { + sb.append(this.dataRegistryURL); + } + first = false; + } + if (isSetPersistOutputData()) { + if (!first) sb.append(", "); + sb.append("persistOutputData:"); + sb.append(this.persistOutputData); + first = false; + } + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. + __isset_bitfield = 0; + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class AdvancedOutputDataHandlingStandardSchemeFactory implements SchemeFactory { + public AdvancedOutputDataHandlingStandardScheme getScheme() { + return new AdvancedOutputDataHandlingStandardScheme(); + } + } + + private static class AdvancedOutputDataHandlingStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, AdvancedOutputDataHandling struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 2: // OUTPUTDATA_DIR + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.outputdataDir = iprot.readString(); + struct.setOutputdataDirIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // DATA_REGISTRY_URL + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.dataRegistryURL = iprot.readString(); + struct.setDataRegistryURLIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // PERSIST_OUTPUT_DATA + if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { + struct.persistOutputData = iprot.readBool(); + struct.setPersistOutputDataIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, AdvancedOutputDataHandling struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.outputdataDir != null) { + if (struct.isSetOutputdataDir()) { + oprot.writeFieldBegin(OUTPUTDATA_DIR_FIELD_DESC); + oprot.writeString(struct.outputdataDir); + oprot.writeFieldEnd(); + } + } + if (struct.dataRegistryURL != null) { + if (struct.isSetDataRegistryURL()) { + oprot.writeFieldBegin(DATA_REGISTRY_URL_FIELD_DESC); + oprot.writeString(struct.dataRegistryURL); + oprot.writeFieldEnd(); + } + } + if (struct.isSetPersistOutputData()) { + oprot.writeFieldBegin(PERSIST_OUTPUT_DATA_FIELD_DESC); + oprot.writeBool(struct.persistOutputData); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AdvancedOutputDataHandlingTupleSchemeFactory implements SchemeFactory { + public AdvancedOutputDataHandlingTupleScheme getScheme() { + return new AdvancedOutputDataHandlingTupleScheme(); + } + } + + private static class AdvancedOutputDataHandlingTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, AdvancedOutputDataHandling struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetOutputdataDir()) { + optionals.set(0); + } + if (struct.isSetDataRegistryURL()) { + optionals.set(1); + } + if (struct.isSetPersistOutputData()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); + if (struct.isSetOutputdataDir()) { + oprot.writeString(struct.outputdataDir); + } + if (struct.isSetDataRegistryURL()) { + oprot.writeString(struct.dataRegistryURL); + } + if (struct.isSetPersistOutputData()) { + oprot.writeBool(struct.persistOutputData); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, AdvancedOutputDataHandling struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(3); + if (incoming.get(0)) { + struct.outputdataDir = iprot.readString(); + struct.setOutputdataDirIsSet(true); + } + if (incoming.get(1)) { + struct.dataRegistryURL = iprot.readString(); + struct.setDataRegistryURLIsSet(true); + } + if (incoming.get(2)) { + struct.persistOutputData = iprot.readBool(); + struct.setPersistOutputDataIsSet(true); + } + } + } + +} +