http://git-wip-us.apache.org/repos/asf/airavata/blob/25da582a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/scheduling/ComputationalResourceSchedulingModel.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/scheduling/ComputationalResourceSchedulingModel.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/scheduling/ComputationalResourceSchedulingModel.java new file mode 100644 index 0000000..08b807f --- /dev/null +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/scheduling/ComputationalResourceSchedulingModel.java @@ -0,0 +1,1243 @@ +/** + * 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.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.airavata.model.scheduling; + +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 javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +/** + * ComputationalResourceSchedulingModel: + * + * + */ +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-2") +public class ComputationalResourceSchedulingModel implements org.apache.thrift.TBase<ComputationalResourceSchedulingModel, ComputationalResourceSchedulingModel._Fields>, java.io.Serializable, Cloneable, Comparable<ComputationalResourceSchedulingModel> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComputationalResourceSchedulingModel"); + + private static final org.apache.thrift.protocol.TField RESOURCE_HOST_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("resourceHostId", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField TOTAL_CPUCOUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("totalCPUCount", org.apache.thrift.protocol.TType.I32, (short)2); + private static final org.apache.thrift.protocol.TField NODE_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("nodeCount", org.apache.thrift.protocol.TType.I32, (short)3); + private static final org.apache.thrift.protocol.TField NUMBER_OF_THREADS_FIELD_DESC = new org.apache.thrift.protocol.TField("numberOfThreads", org.apache.thrift.protocol.TType.I32, (short)4); + private static final org.apache.thrift.protocol.TField QUEUE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("queueName", org.apache.thrift.protocol.TType.STRING, (short)5); + private static final org.apache.thrift.protocol.TField WALL_TIME_LIMIT_FIELD_DESC = new org.apache.thrift.protocol.TField("wallTimeLimit", org.apache.thrift.protocol.TType.I32, (short)6); + private static final org.apache.thrift.protocol.TField TOTAL_PHYSICAL_MEMORY_FIELD_DESC = new org.apache.thrift.protocol.TField("totalPhysicalMemory", org.apache.thrift.protocol.TType.I32, (short)7); + private static final org.apache.thrift.protocol.TField CHESSIS_NUMBER_FIELD_DESC = new org.apache.thrift.protocol.TField("chessisNumber", org.apache.thrift.protocol.TType.STRING, (short)8); + private static final org.apache.thrift.protocol.TField STATIC_WORKING_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("staticWorkingDir", org.apache.thrift.protocol.TType.STRING, (short)9); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new ComputationalResourceSchedulingModelStandardSchemeFactory()); + schemes.put(TupleScheme.class, new ComputationalResourceSchedulingModelTupleSchemeFactory()); + } + + public String resourceHostId; // optional + public int totalCPUCount; // optional + public int nodeCount; // optional + public int numberOfThreads; // optional + public String queueName; // optional + public int wallTimeLimit; // optional + public int totalPhysicalMemory; // optional + public String chessisNumber; // optional + public String staticWorkingDir; // optional + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + RESOURCE_HOST_ID((short)1, "resourceHostId"), + TOTAL_CPUCOUNT((short)2, "totalCPUCount"), + NODE_COUNT((short)3, "nodeCount"), + NUMBER_OF_THREADS((short)4, "numberOfThreads"), + QUEUE_NAME((short)5, "queueName"), + WALL_TIME_LIMIT((short)6, "wallTimeLimit"), + TOTAL_PHYSICAL_MEMORY((short)7, "totalPhysicalMemory"), + CHESSIS_NUMBER((short)8, "chessisNumber"), + STATIC_WORKING_DIR((short)9, "staticWorkingDir"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + 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: // RESOURCE_HOST_ID + return RESOURCE_HOST_ID; + case 2: // TOTAL_CPUCOUNT + return TOTAL_CPUCOUNT; + case 3: // NODE_COUNT + return NODE_COUNT; + case 4: // NUMBER_OF_THREADS + return NUMBER_OF_THREADS; + case 5: // QUEUE_NAME + return QUEUE_NAME; + case 6: // WALL_TIME_LIMIT + return WALL_TIME_LIMIT; + case 7: // TOTAL_PHYSICAL_MEMORY + return TOTAL_PHYSICAL_MEMORY; + case 8: // CHESSIS_NUMBER + return CHESSIS_NUMBER; + case 9: // STATIC_WORKING_DIR + return STATIC_WORKING_DIR; + 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 __TOTALCPUCOUNT_ISSET_ID = 0; + private static final int __NODECOUNT_ISSET_ID = 1; + private static final int __NUMBEROFTHREADS_ISSET_ID = 2; + private static final int __WALLTIMELIMIT_ISSET_ID = 3; + private static final int __TOTALPHYSICALMEMORY_ISSET_ID = 4; + private byte __isset_bitfield = 0; + private static final _Fields optionals[] = {_Fields.RESOURCE_HOST_ID,_Fields.TOTAL_CPUCOUNT,_Fields.NODE_COUNT,_Fields.NUMBER_OF_THREADS,_Fields.QUEUE_NAME,_Fields.WALL_TIME_LIMIT,_Fields.TOTAL_PHYSICAL_MEMORY,_Fields.CHESSIS_NUMBER,_Fields.STATIC_WORKING_DIR}; + 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.RESOURCE_HOST_ID, new org.apache.thrift.meta_data.FieldMetaData("resourceHostId", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.TOTAL_CPUCOUNT, new org.apache.thrift.meta_data.FieldMetaData("totalCPUCount", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + tmpMap.put(_Fields.NODE_COUNT, new org.apache.thrift.meta_data.FieldMetaData("nodeCount", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + tmpMap.put(_Fields.NUMBER_OF_THREADS, new org.apache.thrift.meta_data.FieldMetaData("numberOfThreads", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + tmpMap.put(_Fields.QUEUE_NAME, new org.apache.thrift.meta_data.FieldMetaData("queueName", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.WALL_TIME_LIMIT, new org.apache.thrift.meta_data.FieldMetaData("wallTimeLimit", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + tmpMap.put(_Fields.TOTAL_PHYSICAL_MEMORY, new org.apache.thrift.meta_data.FieldMetaData("totalPhysicalMemory", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + tmpMap.put(_Fields.CHESSIS_NUMBER, new org.apache.thrift.meta_data.FieldMetaData("chessisNumber", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.STATIC_WORKING_DIR, new org.apache.thrift.meta_data.FieldMetaData("staticWorkingDir", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ComputationalResourceSchedulingModel.class, metaDataMap); + } + + public ComputationalResourceSchedulingModel() { + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public ComputationalResourceSchedulingModel(ComputationalResourceSchedulingModel other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetResourceHostId()) { + this.resourceHostId = other.resourceHostId; + } + this.totalCPUCount = other.totalCPUCount; + this.nodeCount = other.nodeCount; + this.numberOfThreads = other.numberOfThreads; + if (other.isSetQueueName()) { + this.queueName = other.queueName; + } + this.wallTimeLimit = other.wallTimeLimit; + this.totalPhysicalMemory = other.totalPhysicalMemory; + if (other.isSetChessisNumber()) { + this.chessisNumber = other.chessisNumber; + } + if (other.isSetStaticWorkingDir()) { + this.staticWorkingDir = other.staticWorkingDir; + } + } + + public ComputationalResourceSchedulingModel deepCopy() { + return new ComputationalResourceSchedulingModel(this); + } + + @Override + public void clear() { + this.resourceHostId = null; + setTotalCPUCountIsSet(false); + this.totalCPUCount = 0; + setNodeCountIsSet(false); + this.nodeCount = 0; + setNumberOfThreadsIsSet(false); + this.numberOfThreads = 0; + this.queueName = null; + setWallTimeLimitIsSet(false); + this.wallTimeLimit = 0; + setTotalPhysicalMemoryIsSet(false); + this.totalPhysicalMemory = 0; + this.chessisNumber = null; + this.staticWorkingDir = null; + } + + public String getResourceHostId() { + return this.resourceHostId; + } + + public ComputationalResourceSchedulingModel setResourceHostId(String resourceHostId) { + this.resourceHostId = resourceHostId; + return this; + } + + public void unsetResourceHostId() { + this.resourceHostId = null; + } + + /** Returns true if field resourceHostId is set (has been assigned a value) and false otherwise */ + public boolean isSetResourceHostId() { + return this.resourceHostId != null; + } + + public void setResourceHostIdIsSet(boolean value) { + if (!value) { + this.resourceHostId = null; + } + } + + public int getTotalCPUCount() { + return this.totalCPUCount; + } + + public ComputationalResourceSchedulingModel setTotalCPUCount(int totalCPUCount) { + this.totalCPUCount = totalCPUCount; + setTotalCPUCountIsSet(true); + return this; + } + + public void unsetTotalCPUCount() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TOTALCPUCOUNT_ISSET_ID); + } + + /** Returns true if field totalCPUCount is set (has been assigned a value) and false otherwise */ + public boolean isSetTotalCPUCount() { + return EncodingUtils.testBit(__isset_bitfield, __TOTALCPUCOUNT_ISSET_ID); + } + + public void setTotalCPUCountIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TOTALCPUCOUNT_ISSET_ID, value); + } + + public int getNodeCount() { + return this.nodeCount; + } + + public ComputationalResourceSchedulingModel setNodeCount(int nodeCount) { + this.nodeCount = nodeCount; + setNodeCountIsSet(true); + return this; + } + + public void unsetNodeCount() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NODECOUNT_ISSET_ID); + } + + /** Returns true if field nodeCount is set (has been assigned a value) and false otherwise */ + public boolean isSetNodeCount() { + return EncodingUtils.testBit(__isset_bitfield, __NODECOUNT_ISSET_ID); + } + + public void setNodeCountIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NODECOUNT_ISSET_ID, value); + } + + public int getNumberOfThreads() { + return this.numberOfThreads; + } + + public ComputationalResourceSchedulingModel setNumberOfThreads(int numberOfThreads) { + this.numberOfThreads = numberOfThreads; + setNumberOfThreadsIsSet(true); + return this; + } + + public void unsetNumberOfThreads() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMBEROFTHREADS_ISSET_ID); + } + + /** Returns true if field numberOfThreads is set (has been assigned a value) and false otherwise */ + public boolean isSetNumberOfThreads() { + return EncodingUtils.testBit(__isset_bitfield, __NUMBEROFTHREADS_ISSET_ID); + } + + public void setNumberOfThreadsIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMBEROFTHREADS_ISSET_ID, value); + } + + public String getQueueName() { + return this.queueName; + } + + public ComputationalResourceSchedulingModel setQueueName(String queueName) { + this.queueName = queueName; + return this; + } + + public void unsetQueueName() { + this.queueName = null; + } + + /** Returns true if field queueName is set (has been assigned a value) and false otherwise */ + public boolean isSetQueueName() { + return this.queueName != null; + } + + public void setQueueNameIsSet(boolean value) { + if (!value) { + this.queueName = null; + } + } + + public int getWallTimeLimit() { + return this.wallTimeLimit; + } + + public ComputationalResourceSchedulingModel setWallTimeLimit(int wallTimeLimit) { + this.wallTimeLimit = wallTimeLimit; + setWallTimeLimitIsSet(true); + return this; + } + + public void unsetWallTimeLimit() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __WALLTIMELIMIT_ISSET_ID); + } + + /** Returns true if field wallTimeLimit is set (has been assigned a value) and false otherwise */ + public boolean isSetWallTimeLimit() { + return EncodingUtils.testBit(__isset_bitfield, __WALLTIMELIMIT_ISSET_ID); + } + + public void setWallTimeLimitIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WALLTIMELIMIT_ISSET_ID, value); + } + + public int getTotalPhysicalMemory() { + return this.totalPhysicalMemory; + } + + public ComputationalResourceSchedulingModel setTotalPhysicalMemory(int totalPhysicalMemory) { + this.totalPhysicalMemory = totalPhysicalMemory; + setTotalPhysicalMemoryIsSet(true); + return this; + } + + public void unsetTotalPhysicalMemory() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TOTALPHYSICALMEMORY_ISSET_ID); + } + + /** Returns true if field totalPhysicalMemory is set (has been assigned a value) and false otherwise */ + public boolean isSetTotalPhysicalMemory() { + return EncodingUtils.testBit(__isset_bitfield, __TOTALPHYSICALMEMORY_ISSET_ID); + } + + public void setTotalPhysicalMemoryIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TOTALPHYSICALMEMORY_ISSET_ID, value); + } + + public String getChessisNumber() { + return this.chessisNumber; + } + + public ComputationalResourceSchedulingModel setChessisNumber(String chessisNumber) { + this.chessisNumber = chessisNumber; + return this; + } + + public void unsetChessisNumber() { + this.chessisNumber = null; + } + + /** Returns true if field chessisNumber is set (has been assigned a value) and false otherwise */ + public boolean isSetChessisNumber() { + return this.chessisNumber != null; + } + + public void setChessisNumberIsSet(boolean value) { + if (!value) { + this.chessisNumber = null; + } + } + + public String getStaticWorkingDir() { + return this.staticWorkingDir; + } + + public ComputationalResourceSchedulingModel setStaticWorkingDir(String staticWorkingDir) { + this.staticWorkingDir = staticWorkingDir; + return this; + } + + public void unsetStaticWorkingDir() { + this.staticWorkingDir = null; + } + + /** Returns true if field staticWorkingDir is set (has been assigned a value) and false otherwise */ + public boolean isSetStaticWorkingDir() { + return this.staticWorkingDir != null; + } + + public void setStaticWorkingDirIsSet(boolean value) { + if (!value) { + this.staticWorkingDir = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case RESOURCE_HOST_ID: + if (value == null) { + unsetResourceHostId(); + } else { + setResourceHostId((String)value); + } + break; + + case TOTAL_CPUCOUNT: + if (value == null) { + unsetTotalCPUCount(); + } else { + setTotalCPUCount((Integer)value); + } + break; + + case NODE_COUNT: + if (value == null) { + unsetNodeCount(); + } else { + setNodeCount((Integer)value); + } + break; + + case NUMBER_OF_THREADS: + if (value == null) { + unsetNumberOfThreads(); + } else { + setNumberOfThreads((Integer)value); + } + break; + + case QUEUE_NAME: + if (value == null) { + unsetQueueName(); + } else { + setQueueName((String)value); + } + break; + + case WALL_TIME_LIMIT: + if (value == null) { + unsetWallTimeLimit(); + } else { + setWallTimeLimit((Integer)value); + } + break; + + case TOTAL_PHYSICAL_MEMORY: + if (value == null) { + unsetTotalPhysicalMemory(); + } else { + setTotalPhysicalMemory((Integer)value); + } + break; + + case CHESSIS_NUMBER: + if (value == null) { + unsetChessisNumber(); + } else { + setChessisNumber((String)value); + } + break; + + case STATIC_WORKING_DIR: + if (value == null) { + unsetStaticWorkingDir(); + } else { + setStaticWorkingDir((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case RESOURCE_HOST_ID: + return getResourceHostId(); + + case TOTAL_CPUCOUNT: + return Integer.valueOf(getTotalCPUCount()); + + case NODE_COUNT: + return Integer.valueOf(getNodeCount()); + + case NUMBER_OF_THREADS: + return Integer.valueOf(getNumberOfThreads()); + + case QUEUE_NAME: + return getQueueName(); + + case WALL_TIME_LIMIT: + return Integer.valueOf(getWallTimeLimit()); + + case TOTAL_PHYSICAL_MEMORY: + return Integer.valueOf(getTotalPhysicalMemory()); + + case CHESSIS_NUMBER: + return getChessisNumber(); + + case STATIC_WORKING_DIR: + return getStaticWorkingDir(); + + } + 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 RESOURCE_HOST_ID: + return isSetResourceHostId(); + case TOTAL_CPUCOUNT: + return isSetTotalCPUCount(); + case NODE_COUNT: + return isSetNodeCount(); + case NUMBER_OF_THREADS: + return isSetNumberOfThreads(); + case QUEUE_NAME: + return isSetQueueName(); + case WALL_TIME_LIMIT: + return isSetWallTimeLimit(); + case TOTAL_PHYSICAL_MEMORY: + return isSetTotalPhysicalMemory(); + case CHESSIS_NUMBER: + return isSetChessisNumber(); + case STATIC_WORKING_DIR: + return isSetStaticWorkingDir(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof ComputationalResourceSchedulingModel) + return this.equals((ComputationalResourceSchedulingModel)that); + return false; + } + + public boolean equals(ComputationalResourceSchedulingModel that) { + if (that == null) + return false; + + boolean this_present_resourceHostId = true && this.isSetResourceHostId(); + boolean that_present_resourceHostId = true && that.isSetResourceHostId(); + if (this_present_resourceHostId || that_present_resourceHostId) { + if (!(this_present_resourceHostId && that_present_resourceHostId)) + return false; + if (!this.resourceHostId.equals(that.resourceHostId)) + return false; + } + + boolean this_present_totalCPUCount = true && this.isSetTotalCPUCount(); + boolean that_present_totalCPUCount = true && that.isSetTotalCPUCount(); + if (this_present_totalCPUCount || that_present_totalCPUCount) { + if (!(this_present_totalCPUCount && that_present_totalCPUCount)) + return false; + if (this.totalCPUCount != that.totalCPUCount) + return false; + } + + boolean this_present_nodeCount = true && this.isSetNodeCount(); + boolean that_present_nodeCount = true && that.isSetNodeCount(); + if (this_present_nodeCount || that_present_nodeCount) { + if (!(this_present_nodeCount && that_present_nodeCount)) + return false; + if (this.nodeCount != that.nodeCount) + return false; + } + + boolean this_present_numberOfThreads = true && this.isSetNumberOfThreads(); + boolean that_present_numberOfThreads = true && that.isSetNumberOfThreads(); + if (this_present_numberOfThreads || that_present_numberOfThreads) { + if (!(this_present_numberOfThreads && that_present_numberOfThreads)) + return false; + if (this.numberOfThreads != that.numberOfThreads) + return false; + } + + boolean this_present_queueName = true && this.isSetQueueName(); + boolean that_present_queueName = true && that.isSetQueueName(); + if (this_present_queueName || that_present_queueName) { + if (!(this_present_queueName && that_present_queueName)) + return false; + if (!this.queueName.equals(that.queueName)) + return false; + } + + boolean this_present_wallTimeLimit = true && this.isSetWallTimeLimit(); + boolean that_present_wallTimeLimit = true && that.isSetWallTimeLimit(); + if (this_present_wallTimeLimit || that_present_wallTimeLimit) { + if (!(this_present_wallTimeLimit && that_present_wallTimeLimit)) + return false; + if (this.wallTimeLimit != that.wallTimeLimit) + return false; + } + + boolean this_present_totalPhysicalMemory = true && this.isSetTotalPhysicalMemory(); + boolean that_present_totalPhysicalMemory = true && that.isSetTotalPhysicalMemory(); + if (this_present_totalPhysicalMemory || that_present_totalPhysicalMemory) { + if (!(this_present_totalPhysicalMemory && that_present_totalPhysicalMemory)) + return false; + if (this.totalPhysicalMemory != that.totalPhysicalMemory) + return false; + } + + boolean this_present_chessisNumber = true && this.isSetChessisNumber(); + boolean that_present_chessisNumber = true && that.isSetChessisNumber(); + if (this_present_chessisNumber || that_present_chessisNumber) { + if (!(this_present_chessisNumber && that_present_chessisNumber)) + return false; + if (!this.chessisNumber.equals(that.chessisNumber)) + return false; + } + + boolean this_present_staticWorkingDir = true && this.isSetStaticWorkingDir(); + boolean that_present_staticWorkingDir = true && that.isSetStaticWorkingDir(); + if (this_present_staticWorkingDir || that_present_staticWorkingDir) { + if (!(this_present_staticWorkingDir && that_present_staticWorkingDir)) + return false; + if (!this.staticWorkingDir.equals(that.staticWorkingDir)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_resourceHostId = true && (isSetResourceHostId()); + list.add(present_resourceHostId); + if (present_resourceHostId) + list.add(resourceHostId); + + boolean present_totalCPUCount = true && (isSetTotalCPUCount()); + list.add(present_totalCPUCount); + if (present_totalCPUCount) + list.add(totalCPUCount); + + boolean present_nodeCount = true && (isSetNodeCount()); + list.add(present_nodeCount); + if (present_nodeCount) + list.add(nodeCount); + + boolean present_numberOfThreads = true && (isSetNumberOfThreads()); + list.add(present_numberOfThreads); + if (present_numberOfThreads) + list.add(numberOfThreads); + + boolean present_queueName = true && (isSetQueueName()); + list.add(present_queueName); + if (present_queueName) + list.add(queueName); + + boolean present_wallTimeLimit = true && (isSetWallTimeLimit()); + list.add(present_wallTimeLimit); + if (present_wallTimeLimit) + list.add(wallTimeLimit); + + boolean present_totalPhysicalMemory = true && (isSetTotalPhysicalMemory()); + list.add(present_totalPhysicalMemory); + if (present_totalPhysicalMemory) + list.add(totalPhysicalMemory); + + boolean present_chessisNumber = true && (isSetChessisNumber()); + list.add(present_chessisNumber); + if (present_chessisNumber) + list.add(chessisNumber); + + boolean present_staticWorkingDir = true && (isSetStaticWorkingDir()); + list.add(present_staticWorkingDir); + if (present_staticWorkingDir) + list.add(staticWorkingDir); + + return list.hashCode(); + } + + @Override + public int compareTo(ComputationalResourceSchedulingModel other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetResourceHostId()).compareTo(other.isSetResourceHostId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetResourceHostId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.resourceHostId, other.resourceHostId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTotalCPUCount()).compareTo(other.isSetTotalCPUCount()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTotalCPUCount()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.totalCPUCount, other.totalCPUCount); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetNodeCount()).compareTo(other.isSetNodeCount()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNodeCount()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nodeCount, other.nodeCount); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetNumberOfThreads()).compareTo(other.isSetNumberOfThreads()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNumberOfThreads()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.numberOfThreads, other.numberOfThreads); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetQueueName()).compareTo(other.isSetQueueName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetQueueName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.queueName, other.queueName); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetWallTimeLimit()).compareTo(other.isSetWallTimeLimit()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetWallTimeLimit()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.wallTimeLimit, other.wallTimeLimit); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTotalPhysicalMemory()).compareTo(other.isSetTotalPhysicalMemory()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTotalPhysicalMemory()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.totalPhysicalMemory, other.totalPhysicalMemory); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetChessisNumber()).compareTo(other.isSetChessisNumber()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetChessisNumber()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.chessisNumber, other.chessisNumber); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetStaticWorkingDir()).compareTo(other.isSetStaticWorkingDir()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetStaticWorkingDir()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.staticWorkingDir, other.staticWorkingDir); + 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("ComputationalResourceSchedulingModel("); + boolean first = true; + + if (isSetResourceHostId()) { + sb.append("resourceHostId:"); + if (this.resourceHostId == null) { + sb.append("null"); + } else { + sb.append(this.resourceHostId); + } + first = false; + } + if (isSetTotalCPUCount()) { + if (!first) sb.append(", "); + sb.append("totalCPUCount:"); + sb.append(this.totalCPUCount); + first = false; + } + if (isSetNodeCount()) { + if (!first) sb.append(", "); + sb.append("nodeCount:"); + sb.append(this.nodeCount); + first = false; + } + if (isSetNumberOfThreads()) { + if (!first) sb.append(", "); + sb.append("numberOfThreads:"); + sb.append(this.numberOfThreads); + first = false; + } + if (isSetQueueName()) { + if (!first) sb.append(", "); + sb.append("queueName:"); + if (this.queueName == null) { + sb.append("null"); + } else { + sb.append(this.queueName); + } + first = false; + } + if (isSetWallTimeLimit()) { + if (!first) sb.append(", "); + sb.append("wallTimeLimit:"); + sb.append(this.wallTimeLimit); + first = false; + } + if (isSetTotalPhysicalMemory()) { + if (!first) sb.append(", "); + sb.append("totalPhysicalMemory:"); + sb.append(this.totalPhysicalMemory); + first = false; + } + if (isSetChessisNumber()) { + if (!first) sb.append(", "); + sb.append("chessisNumber:"); + if (this.chessisNumber == null) { + sb.append("null"); + } else { + sb.append(this.chessisNumber); + } + first = false; + } + if (isSetStaticWorkingDir()) { + if (!first) sb.append(", "); + sb.append("staticWorkingDir:"); + if (this.staticWorkingDir == null) { + sb.append("null"); + } else { + sb.append(this.staticWorkingDir); + } + 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 ComputationalResourceSchedulingModelStandardSchemeFactory implements SchemeFactory { + public ComputationalResourceSchedulingModelStandardScheme getScheme() { + return new ComputationalResourceSchedulingModelStandardScheme(); + } + } + + private static class ComputationalResourceSchedulingModelStandardScheme extends StandardScheme<ComputationalResourceSchedulingModel> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, ComputationalResourceSchedulingModel 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: // RESOURCE_HOST_ID + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.resourceHostId = iprot.readString(); + struct.setResourceHostIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // TOTAL_CPUCOUNT + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.totalCPUCount = iprot.readI32(); + struct.setTotalCPUCountIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // NODE_COUNT + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.nodeCount = iprot.readI32(); + struct.setNodeCountIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // NUMBER_OF_THREADS + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.numberOfThreads = iprot.readI32(); + struct.setNumberOfThreadsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // QUEUE_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.queueName = iprot.readString(); + struct.setQueueNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 6: // WALL_TIME_LIMIT + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.wallTimeLimit = iprot.readI32(); + struct.setWallTimeLimitIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 7: // TOTAL_PHYSICAL_MEMORY + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.totalPhysicalMemory = iprot.readI32(); + struct.setTotalPhysicalMemoryIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 8: // CHESSIS_NUMBER + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.chessisNumber = iprot.readString(); + struct.setChessisNumberIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 9: // STATIC_WORKING_DIR + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.staticWorkingDir = iprot.readString(); + struct.setStaticWorkingDirIsSet(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, ComputationalResourceSchedulingModel struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.resourceHostId != null) { + if (struct.isSetResourceHostId()) { + oprot.writeFieldBegin(RESOURCE_HOST_ID_FIELD_DESC); + oprot.writeString(struct.resourceHostId); + oprot.writeFieldEnd(); + } + } + if (struct.isSetTotalCPUCount()) { + oprot.writeFieldBegin(TOTAL_CPUCOUNT_FIELD_DESC); + oprot.writeI32(struct.totalCPUCount); + oprot.writeFieldEnd(); + } + if (struct.isSetNodeCount()) { + oprot.writeFieldBegin(NODE_COUNT_FIELD_DESC); + oprot.writeI32(struct.nodeCount); + oprot.writeFieldEnd(); + } + if (struct.isSetNumberOfThreads()) { + oprot.writeFieldBegin(NUMBER_OF_THREADS_FIELD_DESC); + oprot.writeI32(struct.numberOfThreads); + oprot.writeFieldEnd(); + } + if (struct.queueName != null) { + if (struct.isSetQueueName()) { + oprot.writeFieldBegin(QUEUE_NAME_FIELD_DESC); + oprot.writeString(struct.queueName); + oprot.writeFieldEnd(); + } + } + if (struct.isSetWallTimeLimit()) { + oprot.writeFieldBegin(WALL_TIME_LIMIT_FIELD_DESC); + oprot.writeI32(struct.wallTimeLimit); + oprot.writeFieldEnd(); + } + if (struct.isSetTotalPhysicalMemory()) { + oprot.writeFieldBegin(TOTAL_PHYSICAL_MEMORY_FIELD_DESC); + oprot.writeI32(struct.totalPhysicalMemory); + oprot.writeFieldEnd(); + } + if (struct.chessisNumber != null) { + if (struct.isSetChessisNumber()) { + oprot.writeFieldBegin(CHESSIS_NUMBER_FIELD_DESC); + oprot.writeString(struct.chessisNumber); + oprot.writeFieldEnd(); + } + } + if (struct.staticWorkingDir != null) { + if (struct.isSetStaticWorkingDir()) { + oprot.writeFieldBegin(STATIC_WORKING_DIR_FIELD_DESC); + oprot.writeString(struct.staticWorkingDir); + oprot.writeFieldEnd(); + } + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class ComputationalResourceSchedulingModelTupleSchemeFactory implements SchemeFactory { + public ComputationalResourceSchedulingModelTupleScheme getScheme() { + return new ComputationalResourceSchedulingModelTupleScheme(); + } + } + + private static class ComputationalResourceSchedulingModelTupleScheme extends TupleScheme<ComputationalResourceSchedulingModel> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, ComputationalResourceSchedulingModel struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetResourceHostId()) { + optionals.set(0); + } + if (struct.isSetTotalCPUCount()) { + optionals.set(1); + } + if (struct.isSetNodeCount()) { + optionals.set(2); + } + if (struct.isSetNumberOfThreads()) { + optionals.set(3); + } + if (struct.isSetQueueName()) { + optionals.set(4); + } + if (struct.isSetWallTimeLimit()) { + optionals.set(5); + } + if (struct.isSetTotalPhysicalMemory()) { + optionals.set(6); + } + if (struct.isSetChessisNumber()) { + optionals.set(7); + } + if (struct.isSetStaticWorkingDir()) { + optionals.set(8); + } + oprot.writeBitSet(optionals, 9); + if (struct.isSetResourceHostId()) { + oprot.writeString(struct.resourceHostId); + } + if (struct.isSetTotalCPUCount()) { + oprot.writeI32(struct.totalCPUCount); + } + if (struct.isSetNodeCount()) { + oprot.writeI32(struct.nodeCount); + } + if (struct.isSetNumberOfThreads()) { + oprot.writeI32(struct.numberOfThreads); + } + if (struct.isSetQueueName()) { + oprot.writeString(struct.queueName); + } + if (struct.isSetWallTimeLimit()) { + oprot.writeI32(struct.wallTimeLimit); + } + if (struct.isSetTotalPhysicalMemory()) { + oprot.writeI32(struct.totalPhysicalMemory); + } + if (struct.isSetChessisNumber()) { + oprot.writeString(struct.chessisNumber); + } + if (struct.isSetStaticWorkingDir()) { + oprot.writeString(struct.staticWorkingDir); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, ComputationalResourceSchedulingModel struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(9); + if (incoming.get(0)) { + struct.resourceHostId = iprot.readString(); + struct.setResourceHostIdIsSet(true); + } + if (incoming.get(1)) { + struct.totalCPUCount = iprot.readI32(); + struct.setTotalCPUCountIsSet(true); + } + if (incoming.get(2)) { + struct.nodeCount = iprot.readI32(); + struct.setNodeCountIsSet(true); + } + if (incoming.get(3)) { + struct.numberOfThreads = iprot.readI32(); + struct.setNumberOfThreadsIsSet(true); + } + if (incoming.get(4)) { + struct.queueName = iprot.readString(); + struct.setQueueNameIsSet(true); + } + if (incoming.get(5)) { + struct.wallTimeLimit = iprot.readI32(); + struct.setWallTimeLimitIsSet(true); + } + if (incoming.get(6)) { + struct.totalPhysicalMemory = iprot.readI32(); + struct.setTotalPhysicalMemoryIsSet(true); + } + if (incoming.get(7)) { + struct.chessisNumber = iprot.readString(); + struct.setChessisNumberIsSet(true); + } + if (incoming.get(8)) { + struct.staticWorkingDir = iprot.readString(); + struct.setStaticWorkingDirIsSet(true); + } + } + } + +} +
http://git-wip-us.apache.org/repos/asf/airavata/blob/25da582a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/security/AuthzToken.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/security/AuthzToken.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/security/AuthzToken.java new file mode 100644 index 0000000..b1d1455 --- /dev/null +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/security/AuthzToken.java @@ -0,0 +1,571 @@ +/** + * 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.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.airavata.model.security; + +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 javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-2") +public class AuthzToken implements org.apache.thrift.TBase<AuthzToken, AuthzToken._Fields>, java.io.Serializable, Cloneable, Comparable<AuthzToken> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AuthzToken"); + + private static final org.apache.thrift.protocol.TField ACCESS_TOKEN_FIELD_DESC = new org.apache.thrift.protocol.TField("accessToken", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField CLAIMS_MAP_FIELD_DESC = new org.apache.thrift.protocol.TField("claimsMap", org.apache.thrift.protocol.TType.MAP, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new AuthzTokenStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AuthzTokenTupleSchemeFactory()); + } + + public String accessToken; // required + public Map<String,String> claimsMap; // optional + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + ACCESS_TOKEN((short)1, "accessToken"), + CLAIMS_MAP((short)2, "claimsMap"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + 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: // ACCESS_TOKEN + return ACCESS_TOKEN; + case 2: // CLAIMS_MAP + return CLAIMS_MAP; + 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 _Fields optionals[] = {_Fields.CLAIMS_MAP}; + 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.ACCESS_TOKEN, new org.apache.thrift.meta_data.FieldMetaData("accessToken", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.CLAIMS_MAP, new org.apache.thrift.meta_data.FieldMetaData("claimsMap", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AuthzToken.class, metaDataMap); + } + + public AuthzToken() { + } + + public AuthzToken( + String accessToken) + { + this(); + this.accessToken = accessToken; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public AuthzToken(AuthzToken other) { + if (other.isSetAccessToken()) { + this.accessToken = other.accessToken; + } + if (other.isSetClaimsMap()) { + Map<String,String> __this__claimsMap = new HashMap<String,String>(other.claimsMap); + this.claimsMap = __this__claimsMap; + } + } + + public AuthzToken deepCopy() { + return new AuthzToken(this); + } + + @Override + public void clear() { + this.accessToken = null; + this.claimsMap = null; + } + + public String getAccessToken() { + return this.accessToken; + } + + public AuthzToken setAccessToken(String accessToken) { + this.accessToken = accessToken; + return this; + } + + public void unsetAccessToken() { + this.accessToken = null; + } + + /** Returns true if field accessToken is set (has been assigned a value) and false otherwise */ + public boolean isSetAccessToken() { + return this.accessToken != null; + } + + public void setAccessTokenIsSet(boolean value) { + if (!value) { + this.accessToken = null; + } + } + + public int getClaimsMapSize() { + return (this.claimsMap == null) ? 0 : this.claimsMap.size(); + } + + public void putToClaimsMap(String key, String val) { + if (this.claimsMap == null) { + this.claimsMap = new HashMap<String,String>(); + } + this.claimsMap.put(key, val); + } + + public Map<String,String> getClaimsMap() { + return this.claimsMap; + } + + public AuthzToken setClaimsMap(Map<String,String> claimsMap) { + this.claimsMap = claimsMap; + return this; + } + + public void unsetClaimsMap() { + this.claimsMap = null; + } + + /** Returns true if field claimsMap is set (has been assigned a value) and false otherwise */ + public boolean isSetClaimsMap() { + return this.claimsMap != null; + } + + public void setClaimsMapIsSet(boolean value) { + if (!value) { + this.claimsMap = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case ACCESS_TOKEN: + if (value == null) { + unsetAccessToken(); + } else { + setAccessToken((String)value); + } + break; + + case CLAIMS_MAP: + if (value == null) { + unsetClaimsMap(); + } else { + setClaimsMap((Map<String,String>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case ACCESS_TOKEN: + return getAccessToken(); + + case CLAIMS_MAP: + return getClaimsMap(); + + } + 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 ACCESS_TOKEN: + return isSetAccessToken(); + case CLAIMS_MAP: + return isSetClaimsMap(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AuthzToken) + return this.equals((AuthzToken)that); + return false; + } + + public boolean equals(AuthzToken that) { + if (that == null) + return false; + + boolean this_present_accessToken = true && this.isSetAccessToken(); + boolean that_present_accessToken = true && that.isSetAccessToken(); + if (this_present_accessToken || that_present_accessToken) { + if (!(this_present_accessToken && that_present_accessToken)) + return false; + if (!this.accessToken.equals(that.accessToken)) + return false; + } + + boolean this_present_claimsMap = true && this.isSetClaimsMap(); + boolean that_present_claimsMap = true && that.isSetClaimsMap(); + if (this_present_claimsMap || that_present_claimsMap) { + if (!(this_present_claimsMap && that_present_claimsMap)) + return false; + if (!this.claimsMap.equals(that.claimsMap)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_accessToken = true && (isSetAccessToken()); + list.add(present_accessToken); + if (present_accessToken) + list.add(accessToken); + + boolean present_claimsMap = true && (isSetClaimsMap()); + list.add(present_claimsMap); + if (present_claimsMap) + list.add(claimsMap); + + return list.hashCode(); + } + + @Override + public int compareTo(AuthzToken other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetAccessToken()).compareTo(other.isSetAccessToken()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetAccessToken()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.accessToken, other.accessToken); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetClaimsMap()).compareTo(other.isSetClaimsMap()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetClaimsMap()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.claimsMap, other.claimsMap); + 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("AuthzToken("); + boolean first = true; + + sb.append("accessToken:"); + if (this.accessToken == null) { + sb.append("null"); + } else { + sb.append(this.accessToken); + } + first = false; + if (isSetClaimsMap()) { + if (!first) sb.append(", "); + sb.append("claimsMap:"); + if (this.claimsMap == null) { + sb.append("null"); + } else { + sb.append(this.claimsMap); + } + first = false; + } + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (accessToken == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'accessToken' 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 AuthzTokenStandardSchemeFactory implements SchemeFactory { + public AuthzTokenStandardScheme getScheme() { + return new AuthzTokenStandardScheme(); + } + } + + private static class AuthzTokenStandardScheme extends StandardScheme<AuthzToken> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, AuthzToken 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: // ACCESS_TOKEN + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.accessToken = iprot.readString(); + struct.setAccessTokenIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // CLAIMS_MAP + if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { + { + org.apache.thrift.protocol.TMap _map0 = iprot.readMapBegin(); + struct.claimsMap = new HashMap<String,String>(2*_map0.size); + String _key1; + String _val2; + for (int _i3 = 0; _i3 < _map0.size; ++_i3) + { + _key1 = iprot.readString(); + _val2 = iprot.readString(); + struct.claimsMap.put(_key1, _val2); + } + iprot.readMapEnd(); + } + struct.setClaimsMapIsSet(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, AuthzToken struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.accessToken != null) { + oprot.writeFieldBegin(ACCESS_TOKEN_FIELD_DESC); + oprot.writeString(struct.accessToken); + oprot.writeFieldEnd(); + } + if (struct.claimsMap != null) { + if (struct.isSetClaimsMap()) { + oprot.writeFieldBegin(CLAIMS_MAP_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.claimsMap.size())); + for (Map.Entry<String, String> _iter4 : struct.claimsMap.entrySet()) + { + oprot.writeString(_iter4.getKey()); + oprot.writeString(_iter4.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AuthzTokenTupleSchemeFactory implements SchemeFactory { + public AuthzTokenTupleScheme getScheme() { + return new AuthzTokenTupleScheme(); + } + } + + private static class AuthzTokenTupleScheme extends TupleScheme<AuthzToken> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, AuthzToken struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.accessToken); + BitSet optionals = new BitSet(); + if (struct.isSetClaimsMap()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetClaimsMap()) { + { + oprot.writeI32(struct.claimsMap.size()); + for (Map.Entry<String, String> _iter5 : struct.claimsMap.entrySet()) + { + oprot.writeString(_iter5.getKey()); + oprot.writeString(_iter5.getValue()); + } + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, AuthzToken struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.accessToken = iprot.readString(); + struct.setAccessTokenIsSet(true); + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + { + org.apache.thrift.protocol.TMap _map6 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.claimsMap = new HashMap<String,String>(2*_map6.size); + String _key7; + String _val8; + for (int _i9 = 0; _i9 < _map6.size; ++_i9) + { + _key7 = iprot.readString(); + _val8 = iprot.readString(); + struct.claimsMap.put(_key7, _val8); + } + } + struct.setClaimsMapIsSet(true); + } + } + } + +} + http://git-wip-us.apache.org/repos/asf/airavata/blob/25da582a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/status/ExperimentState.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/status/ExperimentState.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/status/ExperimentState.java new file mode 100644 index 0000000..f135920 --- /dev/null +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/status/ExperimentState.java @@ -0,0 +1,83 @@ +/** + * 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.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.airavata.model.status; + + +import java.util.Map; +import java.util.HashMap; +import org.apache.thrift.TEnum; + +public enum ExperimentState implements org.apache.thrift.TEnum { + CREATED(0), + VALIDATED(1), + SCHEDULED(2), + LAUNCHED(3), + EXECUTING(4), + CANCELING(5), + CANCELED(6), + COMPLETED(7), + FAILED(8); + + private final int value; + + private ExperimentState(int value) { + this.value = value; + } + + /** + * Get the integer value of this enum value, as defined in the Thrift IDL. + */ + public int getValue() { + return value; + } + + /** + * Find a the enum type by its integer value, as defined in the Thrift IDL. + * @return null if the value is not found. + */ + public static ExperimentState findByValue(int value) { + switch (value) { + case 0: + return CREATED; + case 1: + return VALIDATED; + case 2: + return SCHEDULED; + case 3: + return LAUNCHED; + case 4: + return EXECUTING; + case 5: + return CANCELING; + case 6: + return CANCELED; + case 7: + return COMPLETED; + case 8: + return FAILED; + default: + return null; + } + } +}
