Return-Path: X-Original-To: apmail-accumulo-commits-archive@www.apache.org Delivered-To: apmail-accumulo-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 33162E1F9 for ; Sat, 26 Jan 2013 22:18:57 +0000 (UTC) Received: (qmail 77126 invoked by uid 500); 26 Jan 2013 22:18:57 -0000 Delivered-To: apmail-accumulo-commits-archive@accumulo.apache.org Received: (qmail 77093 invoked by uid 500); 26 Jan 2013 22:18:57 -0000 Mailing-List: contact commits-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@accumulo.apache.org Delivered-To: mailing list commits@accumulo.apache.org Received: (qmail 77086 invoked by uid 99); 26 Jan 2013 22:18:57 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 26 Jan 2013 22:18:57 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 26 Jan 2013 22:18:46 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id 082C32388BA6; Sat, 26 Jan 2013 22:18:03 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1438976 [7/8] - in /accumulo/trunk: ./ assemble/ bin/ contrib/ core/ core/src/main/java/org/apache/accumulo/core/cli/ core/src/main/java/org/apache/accumulo/core/client/admin/ core/src/main/java/org/apache/accumulo/core/client/impl/ core/s... Date: Sat, 26 Jan 2013 22:17:56 -0000 To: commits@accumulo.apache.org From: ctubbsii@apache.org X-Mailer: svnmailer-1.0.8-patched Message-Id: <20130126221803.082C32388BA6@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Modified: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/Tracer.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/Tracer.java?rev=1438976&r1=1438967&r2=1438976&view=diff ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/Tracer.java (original) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/Tracer.java Sat Jan 26 22:17:53 2013 @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.accumulo.cloudtrace.instrument; +package org.apache.accumulo.trace.instrument; import java.security.SecureRandom; import java.util.ArrayList; import java.util.List; import java.util.Random; -import org.apache.accumulo.cloudtrace.instrument.impl.NullSpan; -import org.apache.accumulo.cloudtrace.instrument.impl.RootMilliSpan; -import org.apache.accumulo.cloudtrace.instrument.receivers.SpanReceiver; -import org.apache.accumulo.cloudtrace.thrift.TInfo; +import org.apache.accumulo.trace.instrument.impl.NullSpan; +import org.apache.accumulo.trace.instrument.impl.RootMilliSpan; +import org.apache.accumulo.trace.instrument.receivers.SpanReceiver; +import org.apache.accumulo.trace.thrift.TInfo; /** Modified: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/MilliSpan.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/MilliSpan.java?rev=1438976&r1=1438967&r2=1438976&view=diff ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/MilliSpan.java (original) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/MilliSpan.java Sat Jan 26 22:17:53 2013 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.accumulo.cloudtrace.instrument.impl; +package org.apache.accumulo.trace.instrument.impl; import java.security.SecureRandom; import java.util.Collections; @@ -22,8 +22,8 @@ import java.util.HashMap; import java.util.Map; import java.util.Random; -import org.apache.accumulo.cloudtrace.instrument.Span; -import org.apache.accumulo.cloudtrace.instrument.Tracer; +import org.apache.accumulo.trace.instrument.Span; +import org.apache.accumulo.trace.instrument.Tracer; /** @@ -138,4 +138,4 @@ public class MilliSpan implements Span { return Collections.emptyMap(); return Collections.unmodifiableMap(traceInfo); } -} \ No newline at end of file +} Modified: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/NullSpan.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/NullSpan.java?rev=1438976&r1=1438967&r2=1438976&view=diff ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/NullSpan.java (original) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/NullSpan.java Sat Jan 26 22:17:53 2013 @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.accumulo.cloudtrace.instrument.impl; +package org.apache.accumulo.trace.instrument.impl; import java.util.Collections; import java.util.Map; -import org.apache.accumulo.cloudtrace.instrument.Span; +import org.apache.accumulo.trace.instrument.Span; /** Modified: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/RootMilliSpan.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/RootMilliSpan.java?rev=1438976&r1=1438967&r2=1438976&view=diff ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/RootMilliSpan.java (original) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/impl/RootMilliSpan.java Sat Jan 26 22:17:53 2013 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.accumulo.cloudtrace.instrument.impl; +package org.apache.accumulo.trace.instrument.impl; /** * Span that roots the span tree in a process, but perhaps not the whole trace. Modified: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/AsyncSpanReceiver.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/AsyncSpanReceiver.java?rev=1438976&r1=1438967&r2=1438976&view=diff ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/AsyncSpanReceiver.java (original) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/AsyncSpanReceiver.java Sat Jan 26 22:17:53 2013 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.accumulo.cloudtrace.instrument.receivers; +package org.apache.accumulo.trace.instrument.receivers; import java.util.AbstractQueue; import java.util.HashMap; @@ -23,7 +23,7 @@ import java.util.Timer; import java.util.TimerTask; import java.util.concurrent.ConcurrentLinkedQueue; -import org.apache.accumulo.cloudtrace.thrift.RemoteSpan; +import org.apache.accumulo.trace.thrift.RemoteSpan; import org.apache.log4j.Logger; Modified: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/LogSpans.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/LogSpans.java?rev=1438976&r1=1438967&r2=1438976&view=diff ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/LogSpans.java (original) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/LogSpans.java Sat Jan 26 22:17:53 2013 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.accumulo.cloudtrace.instrument.receivers; +package org.apache.accumulo.trace.instrument.receivers; import java.text.DateFormat; import java.text.SimpleDateFormat; Modified: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/SendSpansViaThrift.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/SendSpansViaThrift.java?rev=1438976&r1=1438967&r2=1438976&view=diff ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/SendSpansViaThrift.java (original) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/SendSpansViaThrift.java Sat Jan 26 22:17:53 2013 @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.accumulo.cloudtrace.instrument.receivers; +package org.apache.accumulo.trace.instrument.receivers; import java.net.InetSocketAddress; import java.net.Socket; import java.util.Map; -import org.apache.accumulo.cloudtrace.thrift.RemoteSpan; -import org.apache.accumulo.cloudtrace.thrift.SpanReceiver.Client; +import org.apache.accumulo.trace.thrift.RemoteSpan; +import org.apache.accumulo.trace.thrift.SpanReceiver.Client; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.protocol.TProtocol; import org.apache.thrift.transport.TSocket; Modified: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/SpanReceiver.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/SpanReceiver.java?rev=1438976&r1=1438967&r2=1438976&view=diff ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/SpanReceiver.java (original) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/SpanReceiver.java Sat Jan 26 22:17:53 2013 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.accumulo.cloudtrace.instrument.receivers; +package org.apache.accumulo.trace.instrument.receivers; import java.util.Map; Modified: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/ZooSpanClient.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/ZooSpanClient.java?rev=1438976&r1=1438967&r2=1438976&view=diff ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/ZooSpanClient.java (original) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/receivers/ZooSpanClient.java Sat Jan 26 22:17:53 2013 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.accumulo.cloudtrace.instrument.receivers; +package org.apache.accumulo.trace.instrument.receivers; import java.io.IOException; import java.util.ArrayList; @@ -74,7 +74,7 @@ public class ZooSpanClient extends SendS /* * (non-Javadoc) * - * @see cloudtrace.instrument.receivers.AsyncSpanReceiver#flush() + * @see trace.instrument.receivers.AsyncSpanReceiver#flush() */ @Override public void flush() { @@ -85,7 +85,7 @@ public class ZooSpanClient extends SendS /* * (non-Javadoc) * - * @see cloudtrace.instrument.receivers.AsyncSpanReceiver#sendSpans() + * @see trace.instrument.receivers.AsyncSpanReceiver#sendSpans() */ @Override void sendSpans() { Modified: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/thrift/TraceWrap.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/thrift/TraceWrap.java?rev=1438976&r1=1438967&r2=1438976&view=diff ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/thrift/TraceWrap.java (original) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/instrument/thrift/TraceWrap.java Sat Jan 26 22:17:53 2013 @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.accumulo.cloudtrace.instrument.thrift; +package org.apache.accumulo.trace.instrument.thrift; import java.lang.reflect.InvocationHandler; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.lang.reflect.Proxy; -import org.apache.accumulo.cloudtrace.instrument.Span; -import org.apache.accumulo.cloudtrace.instrument.Trace; -import org.apache.accumulo.cloudtrace.instrument.Tracer; -import org.apache.accumulo.cloudtrace.thrift.TInfo; +import org.apache.accumulo.trace.instrument.Span; +import org.apache.accumulo.trace.instrument.Trace; +import org.apache.accumulo.trace.instrument.Tracer; +import org.apache.accumulo.trace.thrift.TInfo; /** Added: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/RemoteSpan.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/RemoteSpan.java?rev=1438976&view=auto ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/RemoteSpan.java (added) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/RemoteSpan.java Sat Jan 26 22:17:53 2013 @@ -0,0 +1,1239 @@ +/* + * 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.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.accumulo.trace.thrift; + +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 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; + +@SuppressWarnings("all") public class RemoteSpan implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteSpan"); + + private static final org.apache.thrift.protocol.TField SENDER_FIELD_DESC = new org.apache.thrift.protocol.TField("sender", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField SVC_FIELD_DESC = new org.apache.thrift.protocol.TField("svc", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField TRACE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("traceId", org.apache.thrift.protocol.TType.I64, (short)3); + private static final org.apache.thrift.protocol.TField SPAN_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("spanId", org.apache.thrift.protocol.TType.I64, (short)4); + private static final org.apache.thrift.protocol.TField PARENT_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("parentId", org.apache.thrift.protocol.TType.I64, (short)5); + private static final org.apache.thrift.protocol.TField START_FIELD_DESC = new org.apache.thrift.protocol.TField("start", org.apache.thrift.protocol.TType.I64, (short)6); + private static final org.apache.thrift.protocol.TField STOP_FIELD_DESC = new org.apache.thrift.protocol.TField("stop", org.apache.thrift.protocol.TType.I64, (short)7); + private static final org.apache.thrift.protocol.TField DESCRIPTION_FIELD_DESC = new org.apache.thrift.protocol.TField("description", org.apache.thrift.protocol.TType.STRING, (short)8); + private static final org.apache.thrift.protocol.TField DATA_FIELD_DESC = new org.apache.thrift.protocol.TField("data", org.apache.thrift.protocol.TType.MAP, (short)9); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new RemoteSpanStandardSchemeFactory()); + schemes.put(TupleScheme.class, new RemoteSpanTupleSchemeFactory()); + } + + public String sender; // required + public String svc; // required + public long traceId; // required + public long spanId; // required + public long parentId; // required + public long start; // required + public long stop; // required + public String description; // required + public Map data; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + SENDER((short)1, "sender"), + SVC((short)2, "svc"), + TRACE_ID((short)3, "traceId"), + SPAN_ID((short)4, "spanId"), + PARENT_ID((short)5, "parentId"), + START((short)6, "start"), + STOP((short)7, "stop"), + DESCRIPTION((short)8, "description"), + DATA((short)9, "data"); + + private static final Map byName = new HashMap(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // SENDER + return SENDER; + case 2: // SVC + return SVC; + case 3: // TRACE_ID + return TRACE_ID; + case 4: // SPAN_ID + return SPAN_ID; + case 5: // PARENT_ID + return PARENT_ID; + case 6: // START + return START; + case 7: // STOP + return STOP; + case 8: // DESCRIPTION + return DESCRIPTION; + case 9: // DATA + return DATA; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + private static final int __TRACEID_ISSET_ID = 0; + private static final int __SPANID_ISSET_ID = 1; + private static final int __PARENTID_ISSET_ID = 2; + private static final int __START_ISSET_ID = 3; + private static final int __STOP_ISSET_ID = 4; + private byte __isset_bitfield = 0; + 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.SENDER, new org.apache.thrift.meta_data.FieldMetaData("sender", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.SVC, new org.apache.thrift.meta_data.FieldMetaData("svc", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.TRACE_ID, new org.apache.thrift.meta_data.FieldMetaData("traceId", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.SPAN_ID, new org.apache.thrift.meta_data.FieldMetaData("spanId", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.PARENT_ID, new org.apache.thrift.meta_data.FieldMetaData("parentId", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.START, new org.apache.thrift.meta_data.FieldMetaData("start", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.STOP, new org.apache.thrift.meta_data.FieldMetaData("stop", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.DESCRIPTION, new org.apache.thrift.meta_data.FieldMetaData("description", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.DATA, new org.apache.thrift.meta_data.FieldMetaData("data", org.apache.thrift.TFieldRequirementType.DEFAULT, + 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(RemoteSpan.class, metaDataMap); + } + + public RemoteSpan() { + } + + public RemoteSpan( + String sender, + String svc, + long traceId, + long spanId, + long parentId, + long start, + long stop, + String description, + Map data) + { + this(); + this.sender = sender; + this.svc = svc; + this.traceId = traceId; + setTraceIdIsSet(true); + this.spanId = spanId; + setSpanIdIsSet(true); + this.parentId = parentId; + setParentIdIsSet(true); + this.start = start; + setStartIsSet(true); + this.stop = stop; + setStopIsSet(true); + this.description = description; + this.data = data; + } + + /** + * Performs a deep copy on other. + */ + public RemoteSpan(RemoteSpan other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetSender()) { + this.sender = other.sender; + } + if (other.isSetSvc()) { + this.svc = other.svc; + } + this.traceId = other.traceId; + this.spanId = other.spanId; + this.parentId = other.parentId; + this.start = other.start; + this.stop = other.stop; + if (other.isSetDescription()) { + this.description = other.description; + } + if (other.isSetData()) { + Map __this__data = new HashMap(); + for (Map.Entry other_element : other.data.entrySet()) { + + String other_element_key = other_element.getKey(); + String other_element_value = other_element.getValue(); + + String __this__data_copy_key = other_element_key; + + String __this__data_copy_value = other_element_value; + + __this__data.put(__this__data_copy_key, __this__data_copy_value); + } + this.data = __this__data; + } + } + + public RemoteSpan deepCopy() { + return new RemoteSpan(this); + } + + @Override + public void clear() { + this.sender = null; + this.svc = null; + setTraceIdIsSet(false); + this.traceId = 0; + setSpanIdIsSet(false); + this.spanId = 0; + setParentIdIsSet(false); + this.parentId = 0; + setStartIsSet(false); + this.start = 0; + setStopIsSet(false); + this.stop = 0; + this.description = null; + this.data = null; + } + + public String getSender() { + return this.sender; + } + + public RemoteSpan setSender(String sender) { + this.sender = sender; + return this; + } + + public void unsetSender() { + this.sender = null; + } + + /** Returns true if field sender is set (has been assigned a value) and false otherwise */ + public boolean isSetSender() { + return this.sender != null; + } + + public void setSenderIsSet(boolean value) { + if (!value) { + this.sender = null; + } + } + + public String getSvc() { + return this.svc; + } + + public RemoteSpan setSvc(String svc) { + this.svc = svc; + return this; + } + + public void unsetSvc() { + this.svc = null; + } + + /** Returns true if field svc is set (has been assigned a value) and false otherwise */ + public boolean isSetSvc() { + return this.svc != null; + } + + public void setSvcIsSet(boolean value) { + if (!value) { + this.svc = null; + } + } + + public long getTraceId() { + return this.traceId; + } + + public RemoteSpan setTraceId(long traceId) { + this.traceId = traceId; + setTraceIdIsSet(true); + return this; + } + + public void unsetTraceId() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TRACEID_ISSET_ID); + } + + /** Returns true if field traceId is set (has been assigned a value) and false otherwise */ + public boolean isSetTraceId() { + return EncodingUtils.testBit(__isset_bitfield, __TRACEID_ISSET_ID); + } + + public void setTraceIdIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TRACEID_ISSET_ID, value); + } + + public long getSpanId() { + return this.spanId; + } + + public RemoteSpan setSpanId(long spanId) { + this.spanId = spanId; + setSpanIdIsSet(true); + return this; + } + + public void unsetSpanId() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SPANID_ISSET_ID); + } + + /** Returns true if field spanId is set (has been assigned a value) and false otherwise */ + public boolean isSetSpanId() { + return EncodingUtils.testBit(__isset_bitfield, __SPANID_ISSET_ID); + } + + public void setSpanIdIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SPANID_ISSET_ID, value); + } + + public long getParentId() { + return this.parentId; + } + + public RemoteSpan setParentId(long parentId) { + this.parentId = parentId; + setParentIdIsSet(true); + return this; + } + + public void unsetParentId() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PARENTID_ISSET_ID); + } + + /** Returns true if field parentId is set (has been assigned a value) and false otherwise */ + public boolean isSetParentId() { + return EncodingUtils.testBit(__isset_bitfield, __PARENTID_ISSET_ID); + } + + public void setParentIdIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PARENTID_ISSET_ID, value); + } + + public long getStart() { + return this.start; + } + + public RemoteSpan setStart(long start) { + this.start = start; + setStartIsSet(true); + return this; + } + + public void unsetStart() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __START_ISSET_ID); + } + + /** Returns true if field start is set (has been assigned a value) and false otherwise */ + public boolean isSetStart() { + return EncodingUtils.testBit(__isset_bitfield, __START_ISSET_ID); + } + + public void setStartIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __START_ISSET_ID, value); + } + + public long getStop() { + return this.stop; + } + + public RemoteSpan setStop(long stop) { + this.stop = stop; + setStopIsSet(true); + return this; + } + + public void unsetStop() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __STOP_ISSET_ID); + } + + /** Returns true if field stop is set (has been assigned a value) and false otherwise */ + public boolean isSetStop() { + return EncodingUtils.testBit(__isset_bitfield, __STOP_ISSET_ID); + } + + public void setStopIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __STOP_ISSET_ID, value); + } + + public String getDescription() { + return this.description; + } + + public RemoteSpan setDescription(String description) { + this.description = description; + return this; + } + + public void unsetDescription() { + this.description = null; + } + + /** Returns true if field description is set (has been assigned a value) and false otherwise */ + public boolean isSetDescription() { + return this.description != null; + } + + public void setDescriptionIsSet(boolean value) { + if (!value) { + this.description = null; + } + } + + public int getDataSize() { + return (this.data == null) ? 0 : this.data.size(); + } + + public void putToData(String key, String val) { + if (this.data == null) { + this.data = new HashMap(); + } + this.data.put(key, val); + } + + public Map getData() { + return this.data; + } + + public RemoteSpan setData(Map data) { + this.data = data; + return this; + } + + public void unsetData() { + this.data = null; + } + + /** Returns true if field data is set (has been assigned a value) and false otherwise */ + public boolean isSetData() { + return this.data != null; + } + + public void setDataIsSet(boolean value) { + if (!value) { + this.data = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case SENDER: + if (value == null) { + unsetSender(); + } else { + setSender((String)value); + } + break; + + case SVC: + if (value == null) { + unsetSvc(); + } else { + setSvc((String)value); + } + break; + + case TRACE_ID: + if (value == null) { + unsetTraceId(); + } else { + setTraceId((Long)value); + } + break; + + case SPAN_ID: + if (value == null) { + unsetSpanId(); + } else { + setSpanId((Long)value); + } + break; + + case PARENT_ID: + if (value == null) { + unsetParentId(); + } else { + setParentId((Long)value); + } + break; + + case START: + if (value == null) { + unsetStart(); + } else { + setStart((Long)value); + } + break; + + case STOP: + if (value == null) { + unsetStop(); + } else { + setStop((Long)value); + } + break; + + case DESCRIPTION: + if (value == null) { + unsetDescription(); + } else { + setDescription((String)value); + } + break; + + case DATA: + if (value == null) { + unsetData(); + } else { + setData((Map)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case SENDER: + return getSender(); + + case SVC: + return getSvc(); + + case TRACE_ID: + return Long.valueOf(getTraceId()); + + case SPAN_ID: + return Long.valueOf(getSpanId()); + + case PARENT_ID: + return Long.valueOf(getParentId()); + + case START: + return Long.valueOf(getStart()); + + case STOP: + return Long.valueOf(getStop()); + + case DESCRIPTION: + return getDescription(); + + case DATA: + return getData(); + + } + 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 SENDER: + return isSetSender(); + case SVC: + return isSetSvc(); + case TRACE_ID: + return isSetTraceId(); + case SPAN_ID: + return isSetSpanId(); + case PARENT_ID: + return isSetParentId(); + case START: + return isSetStart(); + case STOP: + return isSetStop(); + case DESCRIPTION: + return isSetDescription(); + case DATA: + return isSetData(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof RemoteSpan) + return this.equals((RemoteSpan)that); + return false; + } + + public boolean equals(RemoteSpan that) { + if (that == null) + return false; + + boolean this_present_sender = true && this.isSetSender(); + boolean that_present_sender = true && that.isSetSender(); + if (this_present_sender || that_present_sender) { + if (!(this_present_sender && that_present_sender)) + return false; + if (!this.sender.equals(that.sender)) + return false; + } + + boolean this_present_svc = true && this.isSetSvc(); + boolean that_present_svc = true && that.isSetSvc(); + if (this_present_svc || that_present_svc) { + if (!(this_present_svc && that_present_svc)) + return false; + if (!this.svc.equals(that.svc)) + return false; + } + + boolean this_present_traceId = true; + boolean that_present_traceId = true; + if (this_present_traceId || that_present_traceId) { + if (!(this_present_traceId && that_present_traceId)) + return false; + if (this.traceId != that.traceId) + return false; + } + + boolean this_present_spanId = true; + boolean that_present_spanId = true; + if (this_present_spanId || that_present_spanId) { + if (!(this_present_spanId && that_present_spanId)) + return false; + if (this.spanId != that.spanId) + return false; + } + + boolean this_present_parentId = true; + boolean that_present_parentId = true; + if (this_present_parentId || that_present_parentId) { + if (!(this_present_parentId && that_present_parentId)) + return false; + if (this.parentId != that.parentId) + return false; + } + + boolean this_present_start = true; + boolean that_present_start = true; + if (this_present_start || that_present_start) { + if (!(this_present_start && that_present_start)) + return false; + if (this.start != that.start) + return false; + } + + boolean this_present_stop = true; + boolean that_present_stop = true; + if (this_present_stop || that_present_stop) { + if (!(this_present_stop && that_present_stop)) + return false; + if (this.stop != that.stop) + return false; + } + + boolean this_present_description = true && this.isSetDescription(); + boolean that_present_description = true && that.isSetDescription(); + if (this_present_description || that_present_description) { + if (!(this_present_description && that_present_description)) + return false; + if (!this.description.equals(that.description)) + return false; + } + + boolean this_present_data = true && this.isSetData(); + boolean that_present_data = true && that.isSetData(); + if (this_present_data || that_present_data) { + if (!(this_present_data && that_present_data)) + return false; + if (!this.data.equals(that.data)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(RemoteSpan other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + RemoteSpan typedOther = (RemoteSpan)other; + + lastComparison = Boolean.valueOf(isSetSender()).compareTo(typedOther.isSetSender()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSender()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sender, typedOther.sender); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetSvc()).compareTo(typedOther.isSetSvc()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSvc()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.svc, typedOther.svc); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTraceId()).compareTo(typedOther.isSetTraceId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTraceId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.traceId, typedOther.traceId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetSpanId()).compareTo(typedOther.isSetSpanId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSpanId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.spanId, typedOther.spanId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetParentId()).compareTo(typedOther.isSetParentId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetParentId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.parentId, typedOther.parentId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetStart()).compareTo(typedOther.isSetStart()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetStart()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.start, typedOther.start); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetStop()).compareTo(typedOther.isSetStop()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetStop()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.stop, typedOther.stop); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetDescription()).compareTo(typedOther.isSetDescription()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDescription()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.description, typedOther.description); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetData()).compareTo(typedOther.isSetData()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetData()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.data, typedOther.data); + 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("RemoteSpan("); + boolean first = true; + + sb.append("sender:"); + if (this.sender == null) { + sb.append("null"); + } else { + sb.append(this.sender); + } + first = false; + if (!first) sb.append(", "); + sb.append("svc:"); + if (this.svc == null) { + sb.append("null"); + } else { + sb.append(this.svc); + } + first = false; + if (!first) sb.append(", "); + sb.append("traceId:"); + sb.append(this.traceId); + first = false; + if (!first) sb.append(", "); + sb.append("spanId:"); + sb.append(this.spanId); + first = false; + if (!first) sb.append(", "); + sb.append("parentId:"); + sb.append(this.parentId); + first = false; + if (!first) sb.append(", "); + sb.append("start:"); + sb.append(this.start); + first = false; + if (!first) sb.append(", "); + sb.append("stop:"); + sb.append(this.stop); + first = false; + if (!first) sb.append(", "); + sb.append("description:"); + if (this.description == null) { + sb.append("null"); + } else { + sb.append(this.description); + } + first = false; + if (!first) sb.append(", "); + sb.append("data:"); + if (this.data == null) { + sb.append("null"); + } else { + sb.append(this.data); + } + 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 RemoteSpanStandardSchemeFactory implements SchemeFactory { + public RemoteSpanStandardScheme getScheme() { + return new RemoteSpanStandardScheme(); + } + } + + private static class RemoteSpanStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, RemoteSpan 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: // SENDER + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.sender = iprot.readString(); + struct.setSenderIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // SVC + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.svc = iprot.readString(); + struct.setSvcIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // TRACE_ID + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.traceId = iprot.readI64(); + struct.setTraceIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // SPAN_ID + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.spanId = iprot.readI64(); + struct.setSpanIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // PARENT_ID + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.parentId = iprot.readI64(); + struct.setParentIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 6: // START + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.start = iprot.readI64(); + struct.setStartIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 7: // STOP + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.stop = iprot.readI64(); + struct.setStopIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 8: // DESCRIPTION + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.description = iprot.readString(); + struct.setDescriptionIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 9: // DATA + if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { + { + org.apache.thrift.protocol.TMap _map0 = iprot.readMapBegin(); + struct.data = new HashMap(2*_map0.size); + for (int _i1 = 0; _i1 < _map0.size; ++_i1) + { + String _key2; // required + String _val3; // required + _key2 = iprot.readString(); + _val3 = iprot.readString(); + struct.data.put(_key2, _val3); + } + iprot.readMapEnd(); + } + struct.setDataIsSet(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, RemoteSpan struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.sender != null) { + oprot.writeFieldBegin(SENDER_FIELD_DESC); + oprot.writeString(struct.sender); + oprot.writeFieldEnd(); + } + if (struct.svc != null) { + oprot.writeFieldBegin(SVC_FIELD_DESC); + oprot.writeString(struct.svc); + oprot.writeFieldEnd(); + } + oprot.writeFieldBegin(TRACE_ID_FIELD_DESC); + oprot.writeI64(struct.traceId); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(SPAN_ID_FIELD_DESC); + oprot.writeI64(struct.spanId); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(PARENT_ID_FIELD_DESC); + oprot.writeI64(struct.parentId); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(START_FIELD_DESC); + oprot.writeI64(struct.start); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(STOP_FIELD_DESC); + oprot.writeI64(struct.stop); + oprot.writeFieldEnd(); + if (struct.description != null) { + oprot.writeFieldBegin(DESCRIPTION_FIELD_DESC); + oprot.writeString(struct.description); + oprot.writeFieldEnd(); + } + if (struct.data != null) { + oprot.writeFieldBegin(DATA_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.data.size())); + for (Map.Entry _iter4 : struct.data.entrySet()) + { + oprot.writeString(_iter4.getKey()); + oprot.writeString(_iter4.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class RemoteSpanTupleSchemeFactory implements SchemeFactory { + public RemoteSpanTupleScheme getScheme() { + return new RemoteSpanTupleScheme(); + } + } + + private static class RemoteSpanTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, RemoteSpan struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetSender()) { + optionals.set(0); + } + if (struct.isSetSvc()) { + optionals.set(1); + } + if (struct.isSetTraceId()) { + optionals.set(2); + } + if (struct.isSetSpanId()) { + optionals.set(3); + } + if (struct.isSetParentId()) { + optionals.set(4); + } + if (struct.isSetStart()) { + optionals.set(5); + } + if (struct.isSetStop()) { + optionals.set(6); + } + if (struct.isSetDescription()) { + optionals.set(7); + } + if (struct.isSetData()) { + optionals.set(8); + } + oprot.writeBitSet(optionals, 9); + if (struct.isSetSender()) { + oprot.writeString(struct.sender); + } + if (struct.isSetSvc()) { + oprot.writeString(struct.svc); + } + if (struct.isSetTraceId()) { + oprot.writeI64(struct.traceId); + } + if (struct.isSetSpanId()) { + oprot.writeI64(struct.spanId); + } + if (struct.isSetParentId()) { + oprot.writeI64(struct.parentId); + } + if (struct.isSetStart()) { + oprot.writeI64(struct.start); + } + if (struct.isSetStop()) { + oprot.writeI64(struct.stop); + } + if (struct.isSetDescription()) { + oprot.writeString(struct.description); + } + if (struct.isSetData()) { + { + oprot.writeI32(struct.data.size()); + for (Map.Entry _iter5 : struct.data.entrySet()) + { + oprot.writeString(_iter5.getKey()); + oprot.writeString(_iter5.getValue()); + } + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, RemoteSpan struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(9); + if (incoming.get(0)) { + struct.sender = iprot.readString(); + struct.setSenderIsSet(true); + } + if (incoming.get(1)) { + struct.svc = iprot.readString(); + struct.setSvcIsSet(true); + } + if (incoming.get(2)) { + struct.traceId = iprot.readI64(); + struct.setTraceIdIsSet(true); + } + if (incoming.get(3)) { + struct.spanId = iprot.readI64(); + struct.setSpanIdIsSet(true); + } + if (incoming.get(4)) { + struct.parentId = iprot.readI64(); + struct.setParentIdIsSet(true); + } + if (incoming.get(5)) { + struct.start = iprot.readI64(); + struct.setStartIsSet(true); + } + if (incoming.get(6)) { + struct.stop = iprot.readI64(); + struct.setStopIsSet(true); + } + if (incoming.get(7)) { + struct.description = iprot.readString(); + struct.setDescriptionIsSet(true); + } + if (incoming.get(8)) { + { + 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.data = new HashMap(2*_map6.size); + for (int _i7 = 0; _i7 < _map6.size; ++_i7) + { + String _key8; // required + String _val9; // required + _key8 = iprot.readString(); + _val9 = iprot.readString(); + struct.data.put(_key8, _val9); + } + } + struct.setDataIsSet(true); + } + } + } + +} + Added: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/SpanReceiver.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/SpanReceiver.java?rev=1438976&view=auto ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/SpanReceiver.java (added) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/SpanReceiver.java Sat Jan 26 22:17:53 2013 @@ -0,0 +1,541 @@ +/* + * 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.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.accumulo.trace.thrift; + +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 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; + +@SuppressWarnings("all") public class SpanReceiver { + + public interface Iface { + + public void span(RemoteSpan span) throws org.apache.thrift.TException; + + } + + public interface AsyncIface { + + public void span(RemoteSpan span, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + } + + public static class Client extends org.apache.thrift.TServiceClient implements Iface { + public static class Factory implements org.apache.thrift.TServiceClientFactory { + public Factory() {} + public Client getClient(org.apache.thrift.protocol.TProtocol prot) { + return new Client(prot); + } + public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { + return new Client(iprot, oprot); + } + } + + public Client(org.apache.thrift.protocol.TProtocol prot) + { + super(prot, prot); + } + + public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { + super(iprot, oprot); + } + + public void span(RemoteSpan span) throws org.apache.thrift.TException + { + send_span(span); + } + + public void send_span(RemoteSpan span) throws org.apache.thrift.TException + { + span_args args = new span_args(); + args.setSpan(span); + sendBase("span", args); + } + + } + public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface { + public static class Factory implements org.apache.thrift.async.TAsyncClientFactory { + private org.apache.thrift.async.TAsyncClientManager clientManager; + private org.apache.thrift.protocol.TProtocolFactory protocolFactory; + public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) { + this.clientManager = clientManager; + this.protocolFactory = protocolFactory; + } + public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) { + return new AsyncClient(protocolFactory, clientManager, transport); + } + } + + public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) { + super(protocolFactory, clientManager, transport); + } + + public void span(RemoteSpan span, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + span_call method_call = new span_call(span, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class span_call extends org.apache.thrift.async.TAsyncMethodCall { + private RemoteSpan span; + public span_call(RemoteSpan span, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, true); + this.span = span; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("span", org.apache.thrift.protocol.TMessageType.CALL, 0)); + span_args args = new span_args(); + args.setSpan(span); + args.write(prot); + prot.writeMessageEnd(); + } + + public void getResult() throws org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + } + } + + } + + public static class Processor extends org.apache.thrift.TBaseProcessor implements org.apache.thrift.TProcessor { + private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName()); + public Processor(I iface) { + super(iface, getProcessMap(new HashMap>())); + } + + protected Processor(I iface, Map> processMap) { + super(iface, getProcessMap(processMap)); + } + + private static Map> getProcessMap(Map> processMap) { + processMap.put("span", new span()); + return processMap; + } + + public static class span extends org.apache.thrift.ProcessFunction { + public span() { + super("span"); + } + + public span_args getEmptyArgsInstance() { + return new span_args(); + } + + protected boolean isOneway() { + return true; + } + + public org.apache.thrift.TBase getResult(I iface, span_args args) throws org.apache.thrift.TException { + iface.span(args.span); + return null; + } + } + + } + + public static class span_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("span_args"); + + private static final org.apache.thrift.protocol.TField SPAN_FIELD_DESC = new org.apache.thrift.protocol.TField("span", org.apache.thrift.protocol.TType.STRUCT, (short)1); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new span_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new span_argsTupleSchemeFactory()); + } + + public RemoteSpan span; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + SPAN((short)1, "span"); + + private static final Map byName = new HashMap(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // SPAN + return SPAN; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.SPAN, new org.apache.thrift.meta_data.FieldMetaData("span", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, RemoteSpan.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(span_args.class, metaDataMap); + } + + public span_args() { + } + + public span_args( + RemoteSpan span) + { + this(); + this.span = span; + } + + /** + * Performs a deep copy on other. + */ + public span_args(span_args other) { + if (other.isSetSpan()) { + this.span = new RemoteSpan(other.span); + } + } + + public span_args deepCopy() { + return new span_args(this); + } + + @Override + public void clear() { + this.span = null; + } + + public RemoteSpan getSpan() { + return this.span; + } + + public span_args setSpan(RemoteSpan span) { + this.span = span; + return this; + } + + public void unsetSpan() { + this.span = null; + } + + /** Returns true if field span is set (has been assigned a value) and false otherwise */ + public boolean isSetSpan() { + return this.span != null; + } + + public void setSpanIsSet(boolean value) { + if (!value) { + this.span = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case SPAN: + if (value == null) { + unsetSpan(); + } else { + setSpan((RemoteSpan)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case SPAN: + return getSpan(); + + } + 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 SPAN: + return isSetSpan(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof span_args) + return this.equals((span_args)that); + return false; + } + + public boolean equals(span_args that) { + if (that == null) + return false; + + boolean this_present_span = true && this.isSetSpan(); + boolean that_present_span = true && that.isSetSpan(); + if (this_present_span || that_present_span) { + if (!(this_present_span && that_present_span)) + return false; + if (!this.span.equals(that.span)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(span_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + span_args typedOther = (span_args)other; + + lastComparison = Boolean.valueOf(isSetSpan()).compareTo(typedOther.isSetSpan()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSpan()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.span, typedOther.span); + 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("span_args("); + boolean first = true; + + sb.append("span:"); + if (this.span == null) { + sb.append("null"); + } else { + sb.append(this.span); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + if (span != null) { + span.validate(); + } + } + + 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 span_argsStandardSchemeFactory implements SchemeFactory { + public span_argsStandardScheme getScheme() { + return new span_argsStandardScheme(); + } + } + + private static class span_argsStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, span_args 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: // SPAN + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.span = new RemoteSpan(); + struct.span.read(iprot); + struct.setSpanIsSet(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, span_args struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.span != null) { + oprot.writeFieldBegin(SPAN_FIELD_DESC); + struct.span.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class span_argsTupleSchemeFactory implements SchemeFactory { + public span_argsTupleScheme getScheme() { + return new span_argsTupleScheme(); + } + } + + private static class span_argsTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, span_args struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetSpan()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetSpan()) { + struct.span.write(oprot); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, span_args struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.span = new RemoteSpan(); + struct.span.read(iprot); + struct.setSpanIsSet(true); + } + } + } + + } + +} Added: accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/TInfo.java URL: http://svn.apache.org/viewvc/accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/TInfo.java?rev=1438976&view=auto ============================================================================== --- accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/TInfo.java (added) +++ accumulo/trunk/trace/src/main/java/org/apache/accumulo/trace/thrift/TInfo.java Sat Jan 26 22:17:53 2013 @@ -0,0 +1,494 @@ +/* + * 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.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.accumulo.trace.thrift; + +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 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; + +@SuppressWarnings("all") public class TInfo implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TInfo"); + + private static final org.apache.thrift.protocol.TField TRACE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("traceId", org.apache.thrift.protocol.TType.I64, (short)1); + private static final org.apache.thrift.protocol.TField PARENT_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("parentId", org.apache.thrift.protocol.TType.I64, (short)2); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new TInfoStandardSchemeFactory()); + schemes.put(TupleScheme.class, new TInfoTupleSchemeFactory()); + } + + public long traceId; // required + public long parentId; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + TRACE_ID((short)1, "traceId"), + PARENT_ID((short)2, "parentId"); + + private static final Map byName = new HashMap(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // TRACE_ID + return TRACE_ID; + case 2: // PARENT_ID + return PARENT_ID; + 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 __TRACEID_ISSET_ID = 0; + private static final int __PARENTID_ISSET_ID = 1; + private byte __isset_bitfield = 0; + 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.TRACE_ID, new org.apache.thrift.meta_data.FieldMetaData("traceId", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.PARENT_ID, new org.apache.thrift.meta_data.FieldMetaData("parentId", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TInfo.class, metaDataMap); + } + + public TInfo() { + } + + public TInfo( + long traceId, + long parentId) + { + this(); + this.traceId = traceId; + setTraceIdIsSet(true); + this.parentId = parentId; + setParentIdIsSet(true); + } + + /** + * Performs a deep copy on other. + */ + public TInfo(TInfo other) { + __isset_bitfield = other.__isset_bitfield; + this.traceId = other.traceId; + this.parentId = other.parentId; + } + + public TInfo deepCopy() { + return new TInfo(this); + } + + @Override + public void clear() { + setTraceIdIsSet(false); + this.traceId = 0; + setParentIdIsSet(false); + this.parentId = 0; + } + + public long getTraceId() { + return this.traceId; + } + + public TInfo setTraceId(long traceId) { + this.traceId = traceId; + setTraceIdIsSet(true); + return this; + } + + public void unsetTraceId() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TRACEID_ISSET_ID); + } + + /** Returns true if field traceId is set (has been assigned a value) and false otherwise */ + public boolean isSetTraceId() { + return EncodingUtils.testBit(__isset_bitfield, __TRACEID_ISSET_ID); + } + + public void setTraceIdIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TRACEID_ISSET_ID, value); + } + + public long getParentId() { + return this.parentId; + } + + public TInfo setParentId(long parentId) { + this.parentId = parentId; + setParentIdIsSet(true); + return this; + } + + public void unsetParentId() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PARENTID_ISSET_ID); + } + + /** Returns true if field parentId is set (has been assigned a value) and false otherwise */ + public boolean isSetParentId() { + return EncodingUtils.testBit(__isset_bitfield, __PARENTID_ISSET_ID); + } + + public void setParentIdIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PARENTID_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case TRACE_ID: + if (value == null) { + unsetTraceId(); + } else { + setTraceId((Long)value); + } + break; + + case PARENT_ID: + if (value == null) { + unsetParentId(); + } else { + setParentId((Long)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case TRACE_ID: + return Long.valueOf(getTraceId()); + + case PARENT_ID: + return Long.valueOf(getParentId()); + + } + 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 TRACE_ID: + return isSetTraceId(); + case PARENT_ID: + return isSetParentId(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof TInfo) + return this.equals((TInfo)that); + return false; + } + + public boolean equals(TInfo that) { + if (that == null) + return false; + + boolean this_present_traceId = true; + boolean that_present_traceId = true; + if (this_present_traceId || that_present_traceId) { + if (!(this_present_traceId && that_present_traceId)) + return false; + if (this.traceId != that.traceId) + return false; + } + + boolean this_present_parentId = true; + boolean that_present_parentId = true; + if (this_present_parentId || that_present_parentId) { + if (!(this_present_parentId && that_present_parentId)) + return false; + if (this.parentId != that.parentId) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(TInfo other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + TInfo typedOther = (TInfo)other; + + lastComparison = Boolean.valueOf(isSetTraceId()).compareTo(typedOther.isSetTraceId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTraceId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.traceId, typedOther.traceId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetParentId()).compareTo(typedOther.isSetParentId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetParentId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.parentId, typedOther.parentId); + 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("TInfo("); + boolean first = true; + + sb.append("traceId:"); + sb.append(this.traceId); + first = false; + if (!first) sb.append(", "); + sb.append("parentId:"); + sb.append(this.parentId); + 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 TInfoStandardSchemeFactory implements SchemeFactory { + public TInfoStandardScheme getScheme() { + return new TInfoStandardScheme(); + } + } + + private static class TInfoStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, TInfo 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: // TRACE_ID + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.traceId = iprot.readI64(); + struct.setTraceIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // PARENT_ID + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.parentId = iprot.readI64(); + struct.setParentIdIsSet(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, TInfo struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldBegin(TRACE_ID_FIELD_DESC); + oprot.writeI64(struct.traceId); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(PARENT_ID_FIELD_DESC); + oprot.writeI64(struct.parentId); + oprot.writeFieldEnd(); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class TInfoTupleSchemeFactory implements SchemeFactory { + public TInfoTupleScheme getScheme() { + return new TInfoTupleScheme(); + } + } + + private static class TInfoTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, TInfo struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetTraceId()) { + optionals.set(0); + } + if (struct.isSetParentId()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetTraceId()) { + oprot.writeI64(struct.traceId); + } + if (struct.isSetParentId()) { + oprot.writeI64(struct.parentId); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, TInfo struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(2); + if (incoming.get(0)) { + struct.traceId = iprot.readI64(); + struct.setTraceIdIsSet(true); + } + if (incoming.get(1)) { + struct.parentId = iprot.readI64(); + struct.setParentIdIsSet(true); + } + } + } + +} +