mirror of
https://github.com/wahyd4/pinpoint.git
synced 2026-08-17 08:46:22 +10:00
[유치수] [NOBTS] create class associated with Tagging.
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@526 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Chisu Yu
@@ -1,52 +0,0 @@
|
||||
package com.profiler.context;
|
||||
|
||||
public class Annotation {
|
||||
|
||||
protected final long timestamp;
|
||||
protected final String value;
|
||||
protected final EndPoint endPoint;
|
||||
|
||||
protected long processStart;
|
||||
protected long processEnd;
|
||||
|
||||
/**
|
||||
* @param timestamp
|
||||
* when was this annotation created? microseconds from epoch
|
||||
* @param value
|
||||
* description of what happened at the timestamp could for
|
||||
* example be "cache miss for key: x"
|
||||
* @param endPoint
|
||||
* host this annotation was created on
|
||||
*/
|
||||
public Annotation(long timestamp, String value, EndPoint endPoint) {
|
||||
this.timestamp = timestamp;
|
||||
this.value = value;
|
||||
this.endPoint = endPoint;
|
||||
}
|
||||
|
||||
public long getTimestamp() {
|
||||
return timestamp;
|
||||
}
|
||||
|
||||
public void processStart() {
|
||||
processStart = System.nanoTime();
|
||||
}
|
||||
|
||||
public void processEnd() {
|
||||
processEnd = System.nanoTime();
|
||||
}
|
||||
|
||||
public String toString() {
|
||||
StringBuilder sb = new StringBuilder();
|
||||
|
||||
sb.append("Annotation={");
|
||||
sb.append("Timestamp=").append(timestamp);
|
||||
sb.append(", Value=").append(value);
|
||||
sb.append(", EndPoint=").append(endPoint);
|
||||
sb.append(", ProcessStart=").append(processStart);
|
||||
sb.append(", ProcessEnd=").append(processEnd);
|
||||
sb.append("}");
|
||||
|
||||
return sb.toString();
|
||||
}
|
||||
}
|
||||
@@ -1,19 +0,0 @@
|
||||
package com.profiler.context;
|
||||
|
||||
public class BinaryAnnotation extends Annotation {
|
||||
|
||||
protected final byte[] binaryValue;
|
||||
|
||||
/**
|
||||
* @param timestamp
|
||||
* when was this annotation created? microseconds from epoch
|
||||
* @param value
|
||||
* detailed description of what happened at the timestamp
|
||||
* @param host
|
||||
* host this annotation was created on
|
||||
*/
|
||||
public BinaryAnnotation(long timestamp, byte[] value, EndPoint host) {
|
||||
super(timestamp, null, host);
|
||||
this.binaryValue = value;
|
||||
}
|
||||
}
|
||||
@@ -1,22 +0,0 @@
|
||||
package com.profiler.context;
|
||||
|
||||
public class EndPoint {
|
||||
|
||||
public static final EndPoint NONE = null;
|
||||
|
||||
private final String protocol;
|
||||
private final String ip;
|
||||
private final int port;
|
||||
private final String name;
|
||||
|
||||
public EndPoint(String protocol, String ip, int port, String name) {
|
||||
this.protocol = protocol;
|
||||
this.ip = ip;
|
||||
this.port = port;
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
public String toString() {
|
||||
return "EndPoint{Protocol=" + protocol + ", IP=" + ip + ", Port=" + port + ", Name=" + name + "]";
|
||||
}
|
||||
}
|
||||
@@ -4,21 +4,21 @@ import com.profiler.util.NamedThreadLocal;
|
||||
|
||||
public class RequestContext {
|
||||
|
||||
private static final ThreadLocal<Span> span = new NamedThreadLocal<Span>("Span");
|
||||
private static final ThreadLocal<Trace> trace = new NamedThreadLocal<Trace>("Trace");
|
||||
|
||||
public static Span getSpan(String traceID, String parentSpanID, String name, boolean debug) {
|
||||
Span ctx = span.get();
|
||||
if (ctx == null) {
|
||||
ctx = new Span(traceID, parentSpanID, name, debug);
|
||||
span.set(ctx);
|
||||
public static Trace getTrace(String traceID, String parentSpanID, String name, boolean debug) {
|
||||
Trace t = trace.get();
|
||||
if (t == null) {
|
||||
t = new Trace(traceID, parentSpanID, name, debug);
|
||||
trace.set(t);
|
||||
}
|
||||
return ctx;
|
||||
return t;
|
||||
}
|
||||
|
||||
/**
|
||||
* Calling from Span.flush()
|
||||
*/
|
||||
public static void removeCurrentContext() {
|
||||
span.remove();
|
||||
trace.remove();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,84 +0,0 @@
|
||||
package com.profiler.context;
|
||||
|
||||
import java.util.Comparator;
|
||||
import java.util.SortedSet;
|
||||
import java.util.TreeSet;
|
||||
|
||||
/**
|
||||
* A span represents one RPC request. A trace is made up of many spans.
|
||||
*
|
||||
* @author netspider
|
||||
*
|
||||
*/
|
||||
public class Span {
|
||||
|
||||
private static final int NO_PARENT_SPAN_ID = -1;
|
||||
|
||||
private final String traceID;
|
||||
private final String spanID;
|
||||
private final String parentSpanID;
|
||||
private final String name;
|
||||
private final long createTime;
|
||||
private final boolean debug;
|
||||
|
||||
private final SortedSet<Annotation> annotations = new TreeSet<Annotation>(new Comparator<Annotation>() {
|
||||
@Override
|
||||
public int compare(Annotation a1, Annotation a2) {
|
||||
return (int) (a1.getTimestamp() - a2.getTimestamp());
|
||||
}
|
||||
});
|
||||
|
||||
/**
|
||||
*
|
||||
* @param traceID
|
||||
* @param parentSpanID
|
||||
* @param name
|
||||
* @param debug
|
||||
* if this is set we will make sure this span is stored, no
|
||||
* matter what the samplers want
|
||||
*/
|
||||
public Span(String traceID, String parentSpanID, String name, boolean debug) {
|
||||
this.traceID = (traceID == null) ? TraceID.newTraceID() : traceID;
|
||||
this.spanID = SpanID.newSpanID();
|
||||
this.parentSpanID = parentSpanID;
|
||||
this.name = name;
|
||||
this.createTime = System.nanoTime();
|
||||
this.debug = debug;
|
||||
}
|
||||
|
||||
public boolean addAnnotation(Annotation annotation) {
|
||||
return annotations.add(annotation);
|
||||
}
|
||||
|
||||
private void flush() {
|
||||
System.out.println("TODO: flush collected data.");
|
||||
RequestContext.removeCurrentContext();
|
||||
}
|
||||
|
||||
public String getTraceID() {
|
||||
return traceID;
|
||||
}
|
||||
|
||||
public boolean isDebug() {
|
||||
return debug;
|
||||
}
|
||||
|
||||
public int getAnnotationSize() {
|
||||
return annotations.size();
|
||||
}
|
||||
|
||||
public String toString() {
|
||||
StringBuilder sb = new StringBuilder();
|
||||
|
||||
sb.append("Span={");
|
||||
sb.append("TraceID=").append(traceID);
|
||||
sb.append(", SpanID=").append(spanID);
|
||||
sb.append(", ParentSpanID=").append(parentSpanID);
|
||||
sb.append(", CreateTime=").append(createTime);
|
||||
sb.append(", Name=").append(name);
|
||||
sb.append(", Annotations=").append(annotations);
|
||||
sb.append("}");
|
||||
|
||||
return sb.toString();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,38 @@
|
||||
package com.profiler.context;
|
||||
|
||||
import com.profiler.context.gen.Annotation;
|
||||
import com.profiler.context.gen.BinaryAnnotation;
|
||||
import com.profiler.context.gen.Span;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author netspider
|
||||
*
|
||||
*/
|
||||
public class Trace {
|
||||
|
||||
private static final int NO_PARENT_SPAN_ID = -1;
|
||||
|
||||
private final String traceID;
|
||||
|
||||
private final Span span;
|
||||
|
||||
Trace(String traceID, String parentSpanID, String name, boolean debug) {
|
||||
this.traceID = (traceID == null) ? TraceID.newTraceID() : traceID;
|
||||
|
||||
this.span = new Span();
|
||||
this.span.setTraceID(this.traceID);
|
||||
this.span.setSpanID(SpanID.newSpanID());
|
||||
this.span.setParentSpanId(parentSpanID);
|
||||
this.span.setName(name);
|
||||
this.span.setDebug(debug);
|
||||
}
|
||||
|
||||
public void record(Annotation annotation) {
|
||||
span.addToAnnotations(annotation);
|
||||
}
|
||||
|
||||
public void recordBinary(BinaryAnnotation annotation) {
|
||||
span.addToBinaryAnnotations(annotation);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,675 @@
|
||||
/**
|
||||
* Autogenerated by Thrift Compiler (0.8.0)
|
||||
*
|
||||
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
||||
* @generated
|
||||
*/
|
||||
package com.profiler.context.gen;
|
||||
|
||||
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 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;
|
||||
|
||||
public class Annotation implements org.apache.thrift.TBase<Annotation, Annotation._Fields>, java.io.Serializable, Cloneable {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Annotation");
|
||||
|
||||
private static final org.apache.thrift.protocol.TField TIMESTAMP_FIELD_DESC = new org.apache.thrift.protocol.TField("timestamp", org.apache.thrift.protocol.TType.I64, (short)1);
|
||||
private static final org.apache.thrift.protocol.TField VALUE_FIELD_DESC = new org.apache.thrift.protocol.TField("value", org.apache.thrift.protocol.TType.STRING, (short)2);
|
||||
private static final org.apache.thrift.protocol.TField HOST_FIELD_DESC = new org.apache.thrift.protocol.TField("host", org.apache.thrift.protocol.TType.STRUCT, (short)3);
|
||||
private static final org.apache.thrift.protocol.TField DURATION_FIELD_DESC = new org.apache.thrift.protocol.TField("duration", org.apache.thrift.protocol.TType.I32, (short)4);
|
||||
|
||||
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
|
||||
static {
|
||||
schemes.put(StandardScheme.class, new AnnotationStandardSchemeFactory());
|
||||
schemes.put(TupleScheme.class, new AnnotationTupleSchemeFactory());
|
||||
}
|
||||
|
||||
private long timestamp; // required
|
||||
private String value; // required
|
||||
private Endpoint host; // optional
|
||||
private int duration; // 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 {
|
||||
TIMESTAMP((short)1, "timestamp"),
|
||||
VALUE((short)2, "value"),
|
||||
HOST((short)3, "host"),
|
||||
DURATION((short)4, "duration");
|
||||
|
||||
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: // TIMESTAMP
|
||||
return TIMESTAMP;
|
||||
case 2: // VALUE
|
||||
return VALUE;
|
||||
case 3: // HOST
|
||||
return HOST;
|
||||
case 4: // DURATION
|
||||
return DURATION;
|
||||
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 __TIMESTAMP_ISSET_ID = 0;
|
||||
private static final int __DURATION_ISSET_ID = 1;
|
||||
private BitSet __isset_bit_vector = new BitSet(2);
|
||||
private _Fields optionals[] = {_Fields.HOST,_Fields.DURATION};
|
||||
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.TIMESTAMP, new org.apache.thrift.meta_data.FieldMetaData("timestamp", org.apache.thrift.TFieldRequirementType.DEFAULT,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
|
||||
tmpMap.put(_Fields.VALUE, new org.apache.thrift.meta_data.FieldMetaData("value", org.apache.thrift.TFieldRequirementType.DEFAULT,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
|
||||
tmpMap.put(_Fields.HOST, new org.apache.thrift.meta_data.FieldMetaData("host", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Endpoint.class)));
|
||||
tmpMap.put(_Fields.DURATION, new org.apache.thrift.meta_data.FieldMetaData("duration", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
|
||||
metaDataMap = Collections.unmodifiableMap(tmpMap);
|
||||
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Annotation.class, metaDataMap);
|
||||
}
|
||||
|
||||
public Annotation() {
|
||||
}
|
||||
|
||||
public Annotation(
|
||||
long timestamp,
|
||||
String value)
|
||||
{
|
||||
this();
|
||||
this.timestamp = timestamp;
|
||||
setTimestampIsSet(true);
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
/**
|
||||
* Performs a deep copy on <i>other</i>.
|
||||
*/
|
||||
public Annotation(Annotation other) {
|
||||
__isset_bit_vector.clear();
|
||||
__isset_bit_vector.or(other.__isset_bit_vector);
|
||||
this.timestamp = other.timestamp;
|
||||
if (other.isSetValue()) {
|
||||
this.value = other.value;
|
||||
}
|
||||
if (other.isSetHost()) {
|
||||
this.host = new Endpoint(other.host);
|
||||
}
|
||||
this.duration = other.duration;
|
||||
}
|
||||
|
||||
public Annotation deepCopy() {
|
||||
return new Annotation(this);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void clear() {
|
||||
setTimestampIsSet(false);
|
||||
this.timestamp = 0;
|
||||
this.value = null;
|
||||
this.host = null;
|
||||
setDurationIsSet(false);
|
||||
this.duration = 0;
|
||||
}
|
||||
|
||||
public long getTimestamp() {
|
||||
return this.timestamp;
|
||||
}
|
||||
|
||||
public void setTimestamp(long timestamp) {
|
||||
this.timestamp = timestamp;
|
||||
setTimestampIsSet(true);
|
||||
}
|
||||
|
||||
public void unsetTimestamp() {
|
||||
__isset_bit_vector.clear(__TIMESTAMP_ISSET_ID);
|
||||
}
|
||||
|
||||
/** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetTimestamp() {
|
||||
return __isset_bit_vector.get(__TIMESTAMP_ISSET_ID);
|
||||
}
|
||||
|
||||
public void setTimestampIsSet(boolean value) {
|
||||
__isset_bit_vector.set(__TIMESTAMP_ISSET_ID, value);
|
||||
}
|
||||
|
||||
public String getValue() {
|
||||
return this.value;
|
||||
}
|
||||
|
||||
public void setValue(String value) {
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
public void unsetValue() {
|
||||
this.value = null;
|
||||
}
|
||||
|
||||
/** Returns true if field value is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetValue() {
|
||||
return this.value != null;
|
||||
}
|
||||
|
||||
public void setValueIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.value = null;
|
||||
}
|
||||
}
|
||||
|
||||
public Endpoint getHost() {
|
||||
return this.host;
|
||||
}
|
||||
|
||||
public void setHost(Endpoint host) {
|
||||
this.host = host;
|
||||
}
|
||||
|
||||
public void unsetHost() {
|
||||
this.host = null;
|
||||
}
|
||||
|
||||
/** Returns true if field host is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetHost() {
|
||||
return this.host != null;
|
||||
}
|
||||
|
||||
public void setHostIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.host = null;
|
||||
}
|
||||
}
|
||||
|
||||
public int getDuration() {
|
||||
return this.duration;
|
||||
}
|
||||
|
||||
public void setDuration(int duration) {
|
||||
this.duration = duration;
|
||||
setDurationIsSet(true);
|
||||
}
|
||||
|
||||
public void unsetDuration() {
|
||||
__isset_bit_vector.clear(__DURATION_ISSET_ID);
|
||||
}
|
||||
|
||||
/** Returns true if field duration is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetDuration() {
|
||||
return __isset_bit_vector.get(__DURATION_ISSET_ID);
|
||||
}
|
||||
|
||||
public void setDurationIsSet(boolean value) {
|
||||
__isset_bit_vector.set(__DURATION_ISSET_ID, value);
|
||||
}
|
||||
|
||||
public void setFieldValue(_Fields field, Object value) {
|
||||
switch (field) {
|
||||
case TIMESTAMP:
|
||||
if (value == null) {
|
||||
unsetTimestamp();
|
||||
} else {
|
||||
setTimestamp((Long)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case VALUE:
|
||||
if (value == null) {
|
||||
unsetValue();
|
||||
} else {
|
||||
setValue((String)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case HOST:
|
||||
if (value == null) {
|
||||
unsetHost();
|
||||
} else {
|
||||
setHost((Endpoint)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case DURATION:
|
||||
if (value == null) {
|
||||
unsetDuration();
|
||||
} else {
|
||||
setDuration((Integer)value);
|
||||
}
|
||||
break;
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
public Object getFieldValue(_Fields field) {
|
||||
switch (field) {
|
||||
case TIMESTAMP:
|
||||
return Long.valueOf(getTimestamp());
|
||||
|
||||
case VALUE:
|
||||
return getValue();
|
||||
|
||||
case HOST:
|
||||
return getHost();
|
||||
|
||||
case DURATION:
|
||||
return Integer.valueOf(getDuration());
|
||||
|
||||
}
|
||||
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 TIMESTAMP:
|
||||
return isSetTimestamp();
|
||||
case VALUE:
|
||||
return isSetValue();
|
||||
case HOST:
|
||||
return isSetHost();
|
||||
case DURATION:
|
||||
return isSetDuration();
|
||||
}
|
||||
throw new IllegalStateException();
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean equals(Object that) {
|
||||
if (that == null)
|
||||
return false;
|
||||
if (that instanceof Annotation)
|
||||
return this.equals((Annotation)that);
|
||||
return false;
|
||||
}
|
||||
|
||||
public boolean equals(Annotation that) {
|
||||
if (that == null)
|
||||
return false;
|
||||
|
||||
boolean this_present_timestamp = true;
|
||||
boolean that_present_timestamp = true;
|
||||
if (this_present_timestamp || that_present_timestamp) {
|
||||
if (!(this_present_timestamp && that_present_timestamp))
|
||||
return false;
|
||||
if (this.timestamp != that.timestamp)
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_value = true && this.isSetValue();
|
||||
boolean that_present_value = true && that.isSetValue();
|
||||
if (this_present_value || that_present_value) {
|
||||
if (!(this_present_value && that_present_value))
|
||||
return false;
|
||||
if (!this.value.equals(that.value))
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_host = true && this.isSetHost();
|
||||
boolean that_present_host = true && that.isSetHost();
|
||||
if (this_present_host || that_present_host) {
|
||||
if (!(this_present_host && that_present_host))
|
||||
return false;
|
||||
if (!this.host.equals(that.host))
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_duration = true && this.isSetDuration();
|
||||
boolean that_present_duration = true && that.isSetDuration();
|
||||
if (this_present_duration || that_present_duration) {
|
||||
if (!(this_present_duration && that_present_duration))
|
||||
return false;
|
||||
if (this.duration != that.duration)
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int hashCode() {
|
||||
return 0;
|
||||
}
|
||||
|
||||
public int compareTo(Annotation other) {
|
||||
if (!getClass().equals(other.getClass())) {
|
||||
return getClass().getName().compareTo(other.getClass().getName());
|
||||
}
|
||||
|
||||
int lastComparison = 0;
|
||||
Annotation typedOther = (Annotation)other;
|
||||
|
||||
lastComparison = Boolean.valueOf(isSetTimestamp()).compareTo(typedOther.isSetTimestamp());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetTimestamp()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.timestamp, typedOther.timestamp);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetValue()).compareTo(typedOther.isSetValue());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetValue()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.value, typedOther.value);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetHost()).compareTo(typedOther.isSetHost());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetHost()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.host, typedOther.host);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetDuration()).compareTo(typedOther.isSetDuration());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetDuration()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.duration, typedOther.duration);
|
||||
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("Annotation(");
|
||||
boolean first = true;
|
||||
|
||||
sb.append("timestamp:");
|
||||
sb.append(this.timestamp);
|
||||
first = false;
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("value:");
|
||||
if (this.value == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.value);
|
||||
}
|
||||
first = false;
|
||||
if (isSetHost()) {
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("host:");
|
||||
if (this.host == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.host);
|
||||
}
|
||||
first = false;
|
||||
}
|
||||
if (isSetDuration()) {
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("duration:");
|
||||
sb.append(this.duration);
|
||||
first = false;
|
||||
}
|
||||
sb.append(")");
|
||||
return sb.toString();
|
||||
}
|
||||
|
||||
public void validate() throws org.apache.thrift.TException {
|
||||
// check for required fields
|
||||
}
|
||||
|
||||
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_bit_vector = new BitSet(1);
|
||||
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 AnnotationStandardSchemeFactory implements SchemeFactory {
|
||||
public AnnotationStandardScheme getScheme() {
|
||||
return new AnnotationStandardScheme();
|
||||
}
|
||||
}
|
||||
|
||||
private static class AnnotationStandardScheme extends StandardScheme<Annotation> {
|
||||
|
||||
public void read(org.apache.thrift.protocol.TProtocol iprot, Annotation 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: // TIMESTAMP
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
|
||||
struct.timestamp = iprot.readI64();
|
||||
struct.setTimestampIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
break;
|
||||
case 2: // VALUE
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
|
||||
struct.value = iprot.readString();
|
||||
struct.setValueIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
break;
|
||||
case 3: // HOST
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
|
||||
struct.host = new Endpoint();
|
||||
struct.host.read(iprot);
|
||||
struct.setHostIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
break;
|
||||
case 4: // DURATION
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
|
||||
struct.duration = iprot.readI32();
|
||||
struct.setDurationIsSet(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();
|
||||
struct.validate();
|
||||
}
|
||||
|
||||
public void write(org.apache.thrift.protocol.TProtocol oprot, Annotation struct) throws org.apache.thrift.TException {
|
||||
struct.validate();
|
||||
|
||||
oprot.writeStructBegin(STRUCT_DESC);
|
||||
oprot.writeFieldBegin(TIMESTAMP_FIELD_DESC);
|
||||
oprot.writeI64(struct.timestamp);
|
||||
oprot.writeFieldEnd();
|
||||
if (struct.value != null) {
|
||||
oprot.writeFieldBegin(VALUE_FIELD_DESC);
|
||||
oprot.writeString(struct.value);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
if (struct.host != null) {
|
||||
if (struct.isSetHost()) {
|
||||
oprot.writeFieldBegin(HOST_FIELD_DESC);
|
||||
struct.host.write(oprot);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
}
|
||||
if (struct.isSetDuration()) {
|
||||
oprot.writeFieldBegin(DURATION_FIELD_DESC);
|
||||
oprot.writeI32(struct.duration);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
oprot.writeFieldStop();
|
||||
oprot.writeStructEnd();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
private static class AnnotationTupleSchemeFactory implements SchemeFactory {
|
||||
public AnnotationTupleScheme getScheme() {
|
||||
return new AnnotationTupleScheme();
|
||||
}
|
||||
}
|
||||
|
||||
private static class AnnotationTupleScheme extends TupleScheme<Annotation> {
|
||||
|
||||
@Override
|
||||
public void write(org.apache.thrift.protocol.TProtocol prot, Annotation struct) throws org.apache.thrift.TException {
|
||||
TTupleProtocol oprot = (TTupleProtocol) prot;
|
||||
BitSet optionals = new BitSet();
|
||||
if (struct.isSetTimestamp()) {
|
||||
optionals.set(0);
|
||||
}
|
||||
if (struct.isSetValue()) {
|
||||
optionals.set(1);
|
||||
}
|
||||
if (struct.isSetHost()) {
|
||||
optionals.set(2);
|
||||
}
|
||||
if (struct.isSetDuration()) {
|
||||
optionals.set(3);
|
||||
}
|
||||
oprot.writeBitSet(optionals, 4);
|
||||
if (struct.isSetTimestamp()) {
|
||||
oprot.writeI64(struct.timestamp);
|
||||
}
|
||||
if (struct.isSetValue()) {
|
||||
oprot.writeString(struct.value);
|
||||
}
|
||||
if (struct.isSetHost()) {
|
||||
struct.host.write(oprot);
|
||||
}
|
||||
if (struct.isSetDuration()) {
|
||||
oprot.writeI32(struct.duration);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void read(org.apache.thrift.protocol.TProtocol prot, Annotation struct) throws org.apache.thrift.TException {
|
||||
TTupleProtocol iprot = (TTupleProtocol) prot;
|
||||
BitSet incoming = iprot.readBitSet(4);
|
||||
if (incoming.get(0)) {
|
||||
struct.timestamp = iprot.readI64();
|
||||
struct.setTimestampIsSet(true);
|
||||
}
|
||||
if (incoming.get(1)) {
|
||||
struct.value = iprot.readString();
|
||||
struct.setValueIsSet(true);
|
||||
}
|
||||
if (incoming.get(2)) {
|
||||
struct.host = new Endpoint();
|
||||
struct.host.read(iprot);
|
||||
struct.setHostIsSet(true);
|
||||
}
|
||||
if (incoming.get(3)) {
|
||||
struct.duration = iprot.readI32();
|
||||
struct.setDurationIsSet(true);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -0,0 +1,789 @@
|
||||
/**
|
||||
* Autogenerated by Thrift Compiler (0.8.0)
|
||||
*
|
||||
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
||||
* @generated
|
||||
*/
|
||||
package com.profiler.context.gen;
|
||||
|
||||
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 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;
|
||||
|
||||
public class BinaryAnnotation implements org.apache.thrift.TBase<BinaryAnnotation, BinaryAnnotation._Fields>, java.io.Serializable, Cloneable {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BinaryAnnotation");
|
||||
|
||||
private static final org.apache.thrift.protocol.TField TIMESTAMP_FIELD_DESC = new org.apache.thrift.protocol.TField("timestamp", org.apache.thrift.protocol.TType.I64, (short)1);
|
||||
private static final org.apache.thrift.protocol.TField KEY_FIELD_DESC = new org.apache.thrift.protocol.TField("key", org.apache.thrift.protocol.TType.STRING, (short)2);
|
||||
private static final org.apache.thrift.protocol.TField VALUE_FIELD_DESC = new org.apache.thrift.protocol.TField("value", org.apache.thrift.protocol.TType.STRING, (short)3);
|
||||
private static final org.apache.thrift.protocol.TField ANNOTATION_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("annotationType", org.apache.thrift.protocol.TType.STRING, (short)4);
|
||||
private static final org.apache.thrift.protocol.TField HOST_FIELD_DESC = new org.apache.thrift.protocol.TField("host", org.apache.thrift.protocol.TType.STRUCT, (short)5);
|
||||
|
||||
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
|
||||
static {
|
||||
schemes.put(StandardScheme.class, new BinaryAnnotationStandardSchemeFactory());
|
||||
schemes.put(TupleScheme.class, new BinaryAnnotationTupleSchemeFactory());
|
||||
}
|
||||
|
||||
private long timestamp; // required
|
||||
private String key; // required
|
||||
private ByteBuffer value; // required
|
||||
private String annotationType; // required
|
||||
private Endpoint host; // 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 {
|
||||
TIMESTAMP((short)1, "timestamp"),
|
||||
KEY((short)2, "key"),
|
||||
VALUE((short)3, "value"),
|
||||
ANNOTATION_TYPE((short)4, "annotationType"),
|
||||
HOST((short)5, "host");
|
||||
|
||||
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: // TIMESTAMP
|
||||
return TIMESTAMP;
|
||||
case 2: // KEY
|
||||
return KEY;
|
||||
case 3: // VALUE
|
||||
return VALUE;
|
||||
case 4: // ANNOTATION_TYPE
|
||||
return ANNOTATION_TYPE;
|
||||
case 5: // HOST
|
||||
return HOST;
|
||||
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 __TIMESTAMP_ISSET_ID = 0;
|
||||
private BitSet __isset_bit_vector = new BitSet(1);
|
||||
private _Fields optionals[] = {_Fields.HOST};
|
||||
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.TIMESTAMP, new org.apache.thrift.meta_data.FieldMetaData("timestamp", org.apache.thrift.TFieldRequirementType.DEFAULT,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
|
||||
tmpMap.put(_Fields.KEY, new org.apache.thrift.meta_data.FieldMetaData("key", org.apache.thrift.TFieldRequirementType.DEFAULT,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
|
||||
tmpMap.put(_Fields.VALUE, new org.apache.thrift.meta_data.FieldMetaData("value", org.apache.thrift.TFieldRequirementType.DEFAULT,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)));
|
||||
tmpMap.put(_Fields.ANNOTATION_TYPE, new org.apache.thrift.meta_data.FieldMetaData("annotationType", org.apache.thrift.TFieldRequirementType.DEFAULT,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
|
||||
tmpMap.put(_Fields.HOST, new org.apache.thrift.meta_data.FieldMetaData("host", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Endpoint.class)));
|
||||
metaDataMap = Collections.unmodifiableMap(tmpMap);
|
||||
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(BinaryAnnotation.class, metaDataMap);
|
||||
}
|
||||
|
||||
public BinaryAnnotation() {
|
||||
}
|
||||
|
||||
public BinaryAnnotation(
|
||||
long timestamp,
|
||||
String key,
|
||||
ByteBuffer value,
|
||||
String annotationType)
|
||||
{
|
||||
this();
|
||||
this.timestamp = timestamp;
|
||||
setTimestampIsSet(true);
|
||||
this.key = key;
|
||||
this.value = value;
|
||||
this.annotationType = annotationType;
|
||||
}
|
||||
|
||||
/**
|
||||
* Performs a deep copy on <i>other</i>.
|
||||
*/
|
||||
public BinaryAnnotation(BinaryAnnotation other) {
|
||||
__isset_bit_vector.clear();
|
||||
__isset_bit_vector.or(other.__isset_bit_vector);
|
||||
this.timestamp = other.timestamp;
|
||||
if (other.isSetKey()) {
|
||||
this.key = other.key;
|
||||
}
|
||||
if (other.isSetValue()) {
|
||||
this.value = org.apache.thrift.TBaseHelper.copyBinary(other.value);
|
||||
;
|
||||
}
|
||||
if (other.isSetAnnotationType()) {
|
||||
this.annotationType = other.annotationType;
|
||||
}
|
||||
if (other.isSetHost()) {
|
||||
this.host = new Endpoint(other.host);
|
||||
}
|
||||
}
|
||||
|
||||
public BinaryAnnotation deepCopy() {
|
||||
return new BinaryAnnotation(this);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void clear() {
|
||||
setTimestampIsSet(false);
|
||||
this.timestamp = 0;
|
||||
this.key = null;
|
||||
this.value = null;
|
||||
this.annotationType = null;
|
||||
this.host = null;
|
||||
}
|
||||
|
||||
public long getTimestamp() {
|
||||
return this.timestamp;
|
||||
}
|
||||
|
||||
public void setTimestamp(long timestamp) {
|
||||
this.timestamp = timestamp;
|
||||
setTimestampIsSet(true);
|
||||
}
|
||||
|
||||
public void unsetTimestamp() {
|
||||
__isset_bit_vector.clear(__TIMESTAMP_ISSET_ID);
|
||||
}
|
||||
|
||||
/** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetTimestamp() {
|
||||
return __isset_bit_vector.get(__TIMESTAMP_ISSET_ID);
|
||||
}
|
||||
|
||||
public void setTimestampIsSet(boolean value) {
|
||||
__isset_bit_vector.set(__TIMESTAMP_ISSET_ID, value);
|
||||
}
|
||||
|
||||
public String getKey() {
|
||||
return this.key;
|
||||
}
|
||||
|
||||
public void setKey(String key) {
|
||||
this.key = key;
|
||||
}
|
||||
|
||||
public void unsetKey() {
|
||||
this.key = null;
|
||||
}
|
||||
|
||||
/** Returns true if field key is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetKey() {
|
||||
return this.key != null;
|
||||
}
|
||||
|
||||
public void setKeyIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.key = null;
|
||||
}
|
||||
}
|
||||
|
||||
public byte[] getValue() {
|
||||
setValue(org.apache.thrift.TBaseHelper.rightSize(value));
|
||||
return value == null ? null : value.array();
|
||||
}
|
||||
|
||||
public ByteBuffer bufferForValue() {
|
||||
return value;
|
||||
}
|
||||
|
||||
public void setValue(byte[] value) {
|
||||
setValue(value == null ? (ByteBuffer)null : ByteBuffer.wrap(value));
|
||||
}
|
||||
|
||||
public void setValue(ByteBuffer value) {
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
public void unsetValue() {
|
||||
this.value = null;
|
||||
}
|
||||
|
||||
/** Returns true if field value is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetValue() {
|
||||
return this.value != null;
|
||||
}
|
||||
|
||||
public void setValueIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.value = null;
|
||||
}
|
||||
}
|
||||
|
||||
public String getAnnotationType() {
|
||||
return this.annotationType;
|
||||
}
|
||||
|
||||
public void setAnnotationType(String annotationType) {
|
||||
this.annotationType = annotationType;
|
||||
}
|
||||
|
||||
public void unsetAnnotationType() {
|
||||
this.annotationType = null;
|
||||
}
|
||||
|
||||
/** Returns true if field annotationType is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetAnnotationType() {
|
||||
return this.annotationType != null;
|
||||
}
|
||||
|
||||
public void setAnnotationTypeIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.annotationType = null;
|
||||
}
|
||||
}
|
||||
|
||||
public Endpoint getHost() {
|
||||
return this.host;
|
||||
}
|
||||
|
||||
public void setHost(Endpoint host) {
|
||||
this.host = host;
|
||||
}
|
||||
|
||||
public void unsetHost() {
|
||||
this.host = null;
|
||||
}
|
||||
|
||||
/** Returns true if field host is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetHost() {
|
||||
return this.host != null;
|
||||
}
|
||||
|
||||
public void setHostIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.host = null;
|
||||
}
|
||||
}
|
||||
|
||||
public void setFieldValue(_Fields field, Object value) {
|
||||
switch (field) {
|
||||
case TIMESTAMP:
|
||||
if (value == null) {
|
||||
unsetTimestamp();
|
||||
} else {
|
||||
setTimestamp((Long)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case KEY:
|
||||
if (value == null) {
|
||||
unsetKey();
|
||||
} else {
|
||||
setKey((String)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case VALUE:
|
||||
if (value == null) {
|
||||
unsetValue();
|
||||
} else {
|
||||
setValue((ByteBuffer)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case ANNOTATION_TYPE:
|
||||
if (value == null) {
|
||||
unsetAnnotationType();
|
||||
} else {
|
||||
setAnnotationType((String)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case HOST:
|
||||
if (value == null) {
|
||||
unsetHost();
|
||||
} else {
|
||||
setHost((Endpoint)value);
|
||||
}
|
||||
break;
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
public Object getFieldValue(_Fields field) {
|
||||
switch (field) {
|
||||
case TIMESTAMP:
|
||||
return Long.valueOf(getTimestamp());
|
||||
|
||||
case KEY:
|
||||
return getKey();
|
||||
|
||||
case VALUE:
|
||||
return getValue();
|
||||
|
||||
case ANNOTATION_TYPE:
|
||||
return getAnnotationType();
|
||||
|
||||
case HOST:
|
||||
return getHost();
|
||||
|
||||
}
|
||||
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 TIMESTAMP:
|
||||
return isSetTimestamp();
|
||||
case KEY:
|
||||
return isSetKey();
|
||||
case VALUE:
|
||||
return isSetValue();
|
||||
case ANNOTATION_TYPE:
|
||||
return isSetAnnotationType();
|
||||
case HOST:
|
||||
return isSetHost();
|
||||
}
|
||||
throw new IllegalStateException();
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean equals(Object that) {
|
||||
if (that == null)
|
||||
return false;
|
||||
if (that instanceof BinaryAnnotation)
|
||||
return this.equals((BinaryAnnotation)that);
|
||||
return false;
|
||||
}
|
||||
|
||||
public boolean equals(BinaryAnnotation that) {
|
||||
if (that == null)
|
||||
return false;
|
||||
|
||||
boolean this_present_timestamp = true;
|
||||
boolean that_present_timestamp = true;
|
||||
if (this_present_timestamp || that_present_timestamp) {
|
||||
if (!(this_present_timestamp && that_present_timestamp))
|
||||
return false;
|
||||
if (this.timestamp != that.timestamp)
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_key = true && this.isSetKey();
|
||||
boolean that_present_key = true && that.isSetKey();
|
||||
if (this_present_key || that_present_key) {
|
||||
if (!(this_present_key && that_present_key))
|
||||
return false;
|
||||
if (!this.key.equals(that.key))
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_value = true && this.isSetValue();
|
||||
boolean that_present_value = true && that.isSetValue();
|
||||
if (this_present_value || that_present_value) {
|
||||
if (!(this_present_value && that_present_value))
|
||||
return false;
|
||||
if (!this.value.equals(that.value))
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_annotationType = true && this.isSetAnnotationType();
|
||||
boolean that_present_annotationType = true && that.isSetAnnotationType();
|
||||
if (this_present_annotationType || that_present_annotationType) {
|
||||
if (!(this_present_annotationType && that_present_annotationType))
|
||||
return false;
|
||||
if (!this.annotationType.equals(that.annotationType))
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_host = true && this.isSetHost();
|
||||
boolean that_present_host = true && that.isSetHost();
|
||||
if (this_present_host || that_present_host) {
|
||||
if (!(this_present_host && that_present_host))
|
||||
return false;
|
||||
if (!this.host.equals(that.host))
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int hashCode() {
|
||||
return 0;
|
||||
}
|
||||
|
||||
public int compareTo(BinaryAnnotation other) {
|
||||
if (!getClass().equals(other.getClass())) {
|
||||
return getClass().getName().compareTo(other.getClass().getName());
|
||||
}
|
||||
|
||||
int lastComparison = 0;
|
||||
BinaryAnnotation typedOther = (BinaryAnnotation)other;
|
||||
|
||||
lastComparison = Boolean.valueOf(isSetTimestamp()).compareTo(typedOther.isSetTimestamp());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetTimestamp()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.timestamp, typedOther.timestamp);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetKey()).compareTo(typedOther.isSetKey());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetKey()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.key, typedOther.key);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetValue()).compareTo(typedOther.isSetValue());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetValue()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.value, typedOther.value);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetAnnotationType()).compareTo(typedOther.isSetAnnotationType());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetAnnotationType()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.annotationType, typedOther.annotationType);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetHost()).compareTo(typedOther.isSetHost());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetHost()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.host, typedOther.host);
|
||||
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("BinaryAnnotation(");
|
||||
boolean first = true;
|
||||
|
||||
sb.append("timestamp:");
|
||||
sb.append(this.timestamp);
|
||||
first = false;
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("key:");
|
||||
if (this.key == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.key);
|
||||
}
|
||||
first = false;
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("value:");
|
||||
if (this.value == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
org.apache.thrift.TBaseHelper.toString(this.value, sb);
|
||||
}
|
||||
first = false;
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("annotationType:");
|
||||
if (this.annotationType == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.annotationType);
|
||||
}
|
||||
first = false;
|
||||
if (isSetHost()) {
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("host:");
|
||||
if (this.host == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.host);
|
||||
}
|
||||
first = false;
|
||||
}
|
||||
sb.append(")");
|
||||
return sb.toString();
|
||||
}
|
||||
|
||||
public void validate() throws org.apache.thrift.TException {
|
||||
// check for required fields
|
||||
}
|
||||
|
||||
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_bit_vector = new BitSet(1);
|
||||
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 BinaryAnnotationStandardSchemeFactory implements SchemeFactory {
|
||||
public BinaryAnnotationStandardScheme getScheme() {
|
||||
return new BinaryAnnotationStandardScheme();
|
||||
}
|
||||
}
|
||||
|
||||
private static class BinaryAnnotationStandardScheme extends StandardScheme<BinaryAnnotation> {
|
||||
|
||||
public void read(org.apache.thrift.protocol.TProtocol iprot, BinaryAnnotation 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: // TIMESTAMP
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
|
||||
struct.timestamp = iprot.readI64();
|
||||
struct.setTimestampIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
break;
|
||||
case 2: // KEY
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
|
||||
struct.key = iprot.readString();
|
||||
struct.setKeyIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
break;
|
||||
case 3: // VALUE
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
|
||||
struct.value = iprot.readBinary();
|
||||
struct.setValueIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
break;
|
||||
case 4: // ANNOTATION_TYPE
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
|
||||
struct.annotationType = iprot.readString();
|
||||
struct.setAnnotationTypeIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
break;
|
||||
case 5: // HOST
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
|
||||
struct.host = new Endpoint();
|
||||
struct.host.read(iprot);
|
||||
struct.setHostIsSet(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();
|
||||
struct.validate();
|
||||
}
|
||||
|
||||
public void write(org.apache.thrift.protocol.TProtocol oprot, BinaryAnnotation struct) throws org.apache.thrift.TException {
|
||||
struct.validate();
|
||||
|
||||
oprot.writeStructBegin(STRUCT_DESC);
|
||||
oprot.writeFieldBegin(TIMESTAMP_FIELD_DESC);
|
||||
oprot.writeI64(struct.timestamp);
|
||||
oprot.writeFieldEnd();
|
||||
if (struct.key != null) {
|
||||
oprot.writeFieldBegin(KEY_FIELD_DESC);
|
||||
oprot.writeString(struct.key);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
if (struct.value != null) {
|
||||
oprot.writeFieldBegin(VALUE_FIELD_DESC);
|
||||
oprot.writeBinary(struct.value);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
if (struct.annotationType != null) {
|
||||
oprot.writeFieldBegin(ANNOTATION_TYPE_FIELD_DESC);
|
||||
oprot.writeString(struct.annotationType);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
if (struct.host != null) {
|
||||
if (struct.isSetHost()) {
|
||||
oprot.writeFieldBegin(HOST_FIELD_DESC);
|
||||
struct.host.write(oprot);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
}
|
||||
oprot.writeFieldStop();
|
||||
oprot.writeStructEnd();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
private static class BinaryAnnotationTupleSchemeFactory implements SchemeFactory {
|
||||
public BinaryAnnotationTupleScheme getScheme() {
|
||||
return new BinaryAnnotationTupleScheme();
|
||||
}
|
||||
}
|
||||
|
||||
private static class BinaryAnnotationTupleScheme extends TupleScheme<BinaryAnnotation> {
|
||||
|
||||
@Override
|
||||
public void write(org.apache.thrift.protocol.TProtocol prot, BinaryAnnotation struct) throws org.apache.thrift.TException {
|
||||
TTupleProtocol oprot = (TTupleProtocol) prot;
|
||||
BitSet optionals = new BitSet();
|
||||
if (struct.isSetTimestamp()) {
|
||||
optionals.set(0);
|
||||
}
|
||||
if (struct.isSetKey()) {
|
||||
optionals.set(1);
|
||||
}
|
||||
if (struct.isSetValue()) {
|
||||
optionals.set(2);
|
||||
}
|
||||
if (struct.isSetAnnotationType()) {
|
||||
optionals.set(3);
|
||||
}
|
||||
if (struct.isSetHost()) {
|
||||
optionals.set(4);
|
||||
}
|
||||
oprot.writeBitSet(optionals, 5);
|
||||
if (struct.isSetTimestamp()) {
|
||||
oprot.writeI64(struct.timestamp);
|
||||
}
|
||||
if (struct.isSetKey()) {
|
||||
oprot.writeString(struct.key);
|
||||
}
|
||||
if (struct.isSetValue()) {
|
||||
oprot.writeBinary(struct.value);
|
||||
}
|
||||
if (struct.isSetAnnotationType()) {
|
||||
oprot.writeString(struct.annotationType);
|
||||
}
|
||||
if (struct.isSetHost()) {
|
||||
struct.host.write(oprot);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void read(org.apache.thrift.protocol.TProtocol prot, BinaryAnnotation struct) throws org.apache.thrift.TException {
|
||||
TTupleProtocol iprot = (TTupleProtocol) prot;
|
||||
BitSet incoming = iprot.readBitSet(5);
|
||||
if (incoming.get(0)) {
|
||||
struct.timestamp = iprot.readI64();
|
||||
struct.setTimestampIsSet(true);
|
||||
}
|
||||
if (incoming.get(1)) {
|
||||
struct.key = iprot.readString();
|
||||
struct.setKeyIsSet(true);
|
||||
}
|
||||
if (incoming.get(2)) {
|
||||
struct.value = iprot.readBinary();
|
||||
struct.setValueIsSet(true);
|
||||
}
|
||||
if (incoming.get(3)) {
|
||||
struct.annotationType = iprot.readString();
|
||||
struct.setAnnotationTypeIsSet(true);
|
||||
}
|
||||
if (incoming.get(4)) {
|
||||
struct.host = new Endpoint();
|
||||
struct.host.read(iprot);
|
||||
struct.setHostIsSet(true);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -0,0 +1,40 @@
|
||||
/**
|
||||
* Autogenerated by Thrift Compiler (0.8.0)
|
||||
*
|
||||
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
||||
* @generated
|
||||
*/
|
||||
package com.profiler.context.gen;
|
||||
|
||||
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 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;
|
||||
|
||||
public class Constants {
|
||||
|
||||
public static final String CLIENT_SEND = "CS";
|
||||
|
||||
public static final String CLIENT_RECV = "CR";
|
||||
|
||||
public static final String SERVER_SEND = "SS";
|
||||
|
||||
public static final String SERVER_RECV = "SR";
|
||||
|
||||
}
|
||||
@@ -0,0 +1,576 @@
|
||||
/**
|
||||
* Autogenerated by Thrift Compiler (0.8.0)
|
||||
*
|
||||
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
||||
* @generated
|
||||
*/
|
||||
package com.profiler.context.gen;
|
||||
|
||||
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 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;
|
||||
|
||||
public class Endpoint implements org.apache.thrift.TBase<Endpoint, Endpoint._Fields>, java.io.Serializable, Cloneable {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Endpoint");
|
||||
|
||||
private static final org.apache.thrift.protocol.TField IP_FIELD_DESC = new org.apache.thrift.protocol.TField("ip", org.apache.thrift.protocol.TType.STRING, (short)1);
|
||||
private static final org.apache.thrift.protocol.TField PORT_FIELD_DESC = new org.apache.thrift.protocol.TField("port", org.apache.thrift.protocol.TType.I16, (short)2);
|
||||
private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)3);
|
||||
|
||||
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
|
||||
static {
|
||||
schemes.put(StandardScheme.class, new EndpointStandardSchemeFactory());
|
||||
schemes.put(TupleScheme.class, new EndpointTupleSchemeFactory());
|
||||
}
|
||||
|
||||
private String ip; // required
|
||||
private short port; // required
|
||||
private String name; // required
|
||||
|
||||
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
|
||||
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
|
||||
IP((short)1, "ip"),
|
||||
PORT((short)2, "port"),
|
||||
NAME((short)3, "name");
|
||||
|
||||
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: // IP
|
||||
return IP;
|
||||
case 2: // PORT
|
||||
return PORT;
|
||||
case 3: // NAME
|
||||
return NAME;
|
||||
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 __PORT_ISSET_ID = 0;
|
||||
private BitSet __isset_bit_vector = new BitSet(1);
|
||||
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.IP, new org.apache.thrift.meta_data.FieldMetaData("ip", org.apache.thrift.TFieldRequirementType.DEFAULT,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
|
||||
tmpMap.put(_Fields.PORT, new org.apache.thrift.meta_data.FieldMetaData("port", org.apache.thrift.TFieldRequirementType.DEFAULT,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I16)));
|
||||
tmpMap.put(_Fields.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.DEFAULT,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
|
||||
metaDataMap = Collections.unmodifiableMap(tmpMap);
|
||||
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Endpoint.class, metaDataMap);
|
||||
}
|
||||
|
||||
public Endpoint() {
|
||||
}
|
||||
|
||||
public Endpoint(
|
||||
String ip,
|
||||
short port,
|
||||
String name)
|
||||
{
|
||||
this();
|
||||
this.ip = ip;
|
||||
this.port = port;
|
||||
setPortIsSet(true);
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
/**
|
||||
* Performs a deep copy on <i>other</i>.
|
||||
*/
|
||||
public Endpoint(Endpoint other) {
|
||||
__isset_bit_vector.clear();
|
||||
__isset_bit_vector.or(other.__isset_bit_vector);
|
||||
if (other.isSetIp()) {
|
||||
this.ip = other.ip;
|
||||
}
|
||||
this.port = other.port;
|
||||
if (other.isSetName()) {
|
||||
this.name = other.name;
|
||||
}
|
||||
}
|
||||
|
||||
public Endpoint deepCopy() {
|
||||
return new Endpoint(this);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void clear() {
|
||||
this.ip = null;
|
||||
setPortIsSet(false);
|
||||
this.port = 0;
|
||||
this.name = null;
|
||||
}
|
||||
|
||||
public String getIp() {
|
||||
return this.ip;
|
||||
}
|
||||
|
||||
public void setIp(String ip) {
|
||||
this.ip = ip;
|
||||
}
|
||||
|
||||
public void unsetIp() {
|
||||
this.ip = null;
|
||||
}
|
||||
|
||||
/** Returns true if field ip is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetIp() {
|
||||
return this.ip != null;
|
||||
}
|
||||
|
||||
public void setIpIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.ip = null;
|
||||
}
|
||||
}
|
||||
|
||||
public short getPort() {
|
||||
return this.port;
|
||||
}
|
||||
|
||||
public void setPort(short port) {
|
||||
this.port = port;
|
||||
setPortIsSet(true);
|
||||
}
|
||||
|
||||
public void unsetPort() {
|
||||
__isset_bit_vector.clear(__PORT_ISSET_ID);
|
||||
}
|
||||
|
||||
/** Returns true if field port is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetPort() {
|
||||
return __isset_bit_vector.get(__PORT_ISSET_ID);
|
||||
}
|
||||
|
||||
public void setPortIsSet(boolean value) {
|
||||
__isset_bit_vector.set(__PORT_ISSET_ID, value);
|
||||
}
|
||||
|
||||
public String getName() {
|
||||
return this.name;
|
||||
}
|
||||
|
||||
public void setName(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
public void unsetName() {
|
||||
this.name = null;
|
||||
}
|
||||
|
||||
/** Returns true if field name is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetName() {
|
||||
return this.name != null;
|
||||
}
|
||||
|
||||
public void setNameIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.name = null;
|
||||
}
|
||||
}
|
||||
|
||||
public void setFieldValue(_Fields field, Object value) {
|
||||
switch (field) {
|
||||
case IP:
|
||||
if (value == null) {
|
||||
unsetIp();
|
||||
} else {
|
||||
setIp((String)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case PORT:
|
||||
if (value == null) {
|
||||
unsetPort();
|
||||
} else {
|
||||
setPort((Short)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case NAME:
|
||||
if (value == null) {
|
||||
unsetName();
|
||||
} else {
|
||||
setName((String)value);
|
||||
}
|
||||
break;
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
public Object getFieldValue(_Fields field) {
|
||||
switch (field) {
|
||||
case IP:
|
||||
return getIp();
|
||||
|
||||
case PORT:
|
||||
return Short.valueOf(getPort());
|
||||
|
||||
case NAME:
|
||||
return getName();
|
||||
|
||||
}
|
||||
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 IP:
|
||||
return isSetIp();
|
||||
case PORT:
|
||||
return isSetPort();
|
||||
case NAME:
|
||||
return isSetName();
|
||||
}
|
||||
throw new IllegalStateException();
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean equals(Object that) {
|
||||
if (that == null)
|
||||
return false;
|
||||
if (that instanceof Endpoint)
|
||||
return this.equals((Endpoint)that);
|
||||
return false;
|
||||
}
|
||||
|
||||
public boolean equals(Endpoint that) {
|
||||
if (that == null)
|
||||
return false;
|
||||
|
||||
boolean this_present_ip = true && this.isSetIp();
|
||||
boolean that_present_ip = true && that.isSetIp();
|
||||
if (this_present_ip || that_present_ip) {
|
||||
if (!(this_present_ip && that_present_ip))
|
||||
return false;
|
||||
if (!this.ip.equals(that.ip))
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_port = true;
|
||||
boolean that_present_port = true;
|
||||
if (this_present_port || that_present_port) {
|
||||
if (!(this_present_port && that_present_port))
|
||||
return false;
|
||||
if (this.port != that.port)
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_name = true && this.isSetName();
|
||||
boolean that_present_name = true && that.isSetName();
|
||||
if (this_present_name || that_present_name) {
|
||||
if (!(this_present_name && that_present_name))
|
||||
return false;
|
||||
if (!this.name.equals(that.name))
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int hashCode() {
|
||||
return 0;
|
||||
}
|
||||
|
||||
public int compareTo(Endpoint other) {
|
||||
if (!getClass().equals(other.getClass())) {
|
||||
return getClass().getName().compareTo(other.getClass().getName());
|
||||
}
|
||||
|
||||
int lastComparison = 0;
|
||||
Endpoint typedOther = (Endpoint)other;
|
||||
|
||||
lastComparison = Boolean.valueOf(isSetIp()).compareTo(typedOther.isSetIp());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetIp()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ip, typedOther.ip);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetPort()).compareTo(typedOther.isSetPort());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetPort()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.port, typedOther.port);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetName()).compareTo(typedOther.isSetName());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetName()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, typedOther.name);
|
||||
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("Endpoint(");
|
||||
boolean first = true;
|
||||
|
||||
sb.append("ip:");
|
||||
if (this.ip == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.ip);
|
||||
}
|
||||
first = false;
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("port:");
|
||||
sb.append(this.port);
|
||||
first = false;
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("name:");
|
||||
if (this.name == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.name);
|
||||
}
|
||||
first = false;
|
||||
sb.append(")");
|
||||
return sb.toString();
|
||||
}
|
||||
|
||||
public void validate() throws org.apache.thrift.TException {
|
||||
// check for required fields
|
||||
}
|
||||
|
||||
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_bit_vector = new BitSet(1);
|
||||
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 EndpointStandardSchemeFactory implements SchemeFactory {
|
||||
public EndpointStandardScheme getScheme() {
|
||||
return new EndpointStandardScheme();
|
||||
}
|
||||
}
|
||||
|
||||
private static class EndpointStandardScheme extends StandardScheme<Endpoint> {
|
||||
|
||||
public void read(org.apache.thrift.protocol.TProtocol iprot, Endpoint 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: // IP
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
|
||||
struct.ip = iprot.readString();
|
||||
struct.setIpIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
break;
|
||||
case 2: // PORT
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.I16) {
|
||||
struct.port = iprot.readI16();
|
||||
struct.setPortIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
break;
|
||||
case 3: // NAME
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
|
||||
struct.name = iprot.readString();
|
||||
struct.setNameIsSet(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();
|
||||
struct.validate();
|
||||
}
|
||||
|
||||
public void write(org.apache.thrift.protocol.TProtocol oprot, Endpoint struct) throws org.apache.thrift.TException {
|
||||
struct.validate();
|
||||
|
||||
oprot.writeStructBegin(STRUCT_DESC);
|
||||
if (struct.ip != null) {
|
||||
oprot.writeFieldBegin(IP_FIELD_DESC);
|
||||
oprot.writeString(struct.ip);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
oprot.writeFieldBegin(PORT_FIELD_DESC);
|
||||
oprot.writeI16(struct.port);
|
||||
oprot.writeFieldEnd();
|
||||
if (struct.name != null) {
|
||||
oprot.writeFieldBegin(NAME_FIELD_DESC);
|
||||
oprot.writeString(struct.name);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
oprot.writeFieldStop();
|
||||
oprot.writeStructEnd();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
private static class EndpointTupleSchemeFactory implements SchemeFactory {
|
||||
public EndpointTupleScheme getScheme() {
|
||||
return new EndpointTupleScheme();
|
||||
}
|
||||
}
|
||||
|
||||
private static class EndpointTupleScheme extends TupleScheme<Endpoint> {
|
||||
|
||||
@Override
|
||||
public void write(org.apache.thrift.protocol.TProtocol prot, Endpoint struct) throws org.apache.thrift.TException {
|
||||
TTupleProtocol oprot = (TTupleProtocol) prot;
|
||||
BitSet optionals = new BitSet();
|
||||
if (struct.isSetIp()) {
|
||||
optionals.set(0);
|
||||
}
|
||||
if (struct.isSetPort()) {
|
||||
optionals.set(1);
|
||||
}
|
||||
if (struct.isSetName()) {
|
||||
optionals.set(2);
|
||||
}
|
||||
oprot.writeBitSet(optionals, 3);
|
||||
if (struct.isSetIp()) {
|
||||
oprot.writeString(struct.ip);
|
||||
}
|
||||
if (struct.isSetPort()) {
|
||||
oprot.writeI16(struct.port);
|
||||
}
|
||||
if (struct.isSetName()) {
|
||||
oprot.writeString(struct.name);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void read(org.apache.thrift.protocol.TProtocol prot, Endpoint struct) throws org.apache.thrift.TException {
|
||||
TTupleProtocol iprot = (TTupleProtocol) prot;
|
||||
BitSet incoming = iprot.readBitSet(3);
|
||||
if (incoming.get(0)) {
|
||||
struct.ip = iprot.readString();
|
||||
struct.setIpIsSet(true);
|
||||
}
|
||||
if (incoming.get(1)) {
|
||||
struct.port = iprot.readI16();
|
||||
struct.setPortIsSet(true);
|
||||
}
|
||||
if (incoming.get(2)) {
|
||||
struct.name = iprot.readString();
|
||||
struct.setNameIsSet(true);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
Reference in New Issue
Block a user