From commits-return-5026-apmail-airavata-commits-archive=airavata.apache.org@airavata.apache.org Mon Feb 10 14:44:44 2014 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 4849110135 for ; Mon, 10 Feb 2014 14:44:44 +0000 (UTC) Received: (qmail 85270 invoked by uid 500); 10 Feb 2014 14:43:57 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 84296 invoked by uid 500); 10 Feb 2014 14:43:27 -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 84078 invoked by uid 99); 10 Feb 2014 14:43:22 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 10 Feb 2014 14:43:22 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 5AD50921F01; Mon, 10 Feb 2014 14:43:22 +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: Mon, 10 Feb 2014 14:43:24 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [03/27] Mock airavata api server and client for AIRAVATA-991 http://git-wip-us.apache.org/repos/asf/airavata/blob/fc927c6c/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 deleted file mode 100644 index a0572d3..0000000 --- a/airavata-api/server/src/main/java/org/apache/airavata/api/error/InvalidRequestException.java +++ /dev/null @@ -1,403 +0,0 @@ - /* - * 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/fc927c6c/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 deleted file mode 100644 index a746de0..0000000 --- a/airavata-api/server/src/main/java/org/apache/airavata/api/error/TimedOutException.java +++ /dev/null @@ -1,299 +0,0 @@ - /* - * 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/fc927c6c/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 deleted file mode 100644 index 4cf5045..0000000 --- a/airavata-api/server/src/main/java/org/apache/airavata/model/experiment/AdvancedInputDataHandling.java +++ /dev/null @@ -1,706 +0,0 @@ - /* - * 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/fc927c6c/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 deleted file mode 100644 index 7bec30e..0000000 --- a/airavata-api/server/src/main/java/org/apache/airavata/model/experiment/AdvancedOutputDataHandling.java +++ /dev/null @@ -1,609 +0,0 @@ - /* - * 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); - } - } - } - -} -