public abstract class org.apache.cassandra.tracing.Tracing implements org.apache.cassandra.concurrent.ExecutorLocal<org.apache.cassandra.tracing.TraceState>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: org.apache.cassandra.tracing.Tracing
super_class: java.lang.Object
{
public static final java.lang.String TRACE_HEADER;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "TraceSession"
public static final java.lang.String TRACE_TYPE;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "TraceType"
protected static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
private final java.net.InetAddress localAddress;
descriptor: Ljava/net/InetAddress;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.netty.util.concurrent.FastThreadLocal<org.apache.cassandra.tracing.TraceState> state;
descriptor: Lio/netty/util/concurrent/FastThreadLocal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/netty/util/concurrent/FastThreadLocal<Lorg/apache/cassandra/tracing/TraceState;>;
protected final java.util.concurrent.ConcurrentMap<java.util.UUID, org.apache.cassandra.tracing.TraceState> sessions;
descriptor: Ljava/util/concurrent/ConcurrentMap;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentMap<Ljava/util/UUID;Lorg/apache/cassandra/tracing/TraceState;>;
public static final org.apache.cassandra.tracing.Tracing instance;
descriptor: Lorg/apache/cassandra/tracing/Tracing;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=6, locals=3, args_size=0
0: ldc Lorg/apache/cassandra/tracing/Tracing;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic org.apache.cassandra.tracing.Tracing.$assertionsDisabled:Z
3: ldc Lorg/apache/cassandra/tracing/Tracing;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.tracing.Tracing.logger:Lorg/slf4j/Logger;
4: aconst_null
astore 0
start local 0 5: ldc "cassandra.custom_tracing_class"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
astore 1
start local 1 6: aload 1
ifnull 13
7: aload 1
ldc "Tracing"
invokestatic org.apache.cassandra.utils.FBUtilities.construct:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
checkcast org.apache.cassandra.tracing.Tracing
astore 0
8: getstatic org.apache.cassandra.tracing.Tracing.logger:Lorg/slf4j/Logger;
ldc "Using {} as tracing queries (as requested with -Dcassandra.custom_tracing_class)"
aload 1
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
9: goto 13
10: StackMap locals: org.apache.cassandra.tracing.Tracing java.lang.String
StackMap stack: java.lang.Exception
astore 2
start local 2 11: aload 2
invokestatic org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable:(Ljava/lang/Throwable;)V
12: getstatic org.apache.cassandra.tracing.Tracing.logger:Lorg/slf4j/Logger;
ldc "Cannot use class %s for tracing, ignoring by defaulting to normal tracing"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
aload 2
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Throwable;)V
end local 2 13: StackMap locals:
StackMap stack:
aload 0
ifnull 14
aload 0
goto 15
StackMap locals:
StackMap stack:
14: new org.apache.cassandra.tracing.TracingImpl
dup
invokespecial org.apache.cassandra.tracing.TracingImpl.<init>:()V
StackMap locals:
StackMap stack: org.apache.cassandra.tracing.Tracing
15: putstatic org.apache.cassandra.tracing.Tracing.instance:Lorg/apache/cassandra/tracing/Tracing;
end local 1 end local 0 16: return
LocalVariableTable:
Start End Slot Name Signature
5 16 0 tracing Lorg/apache/cassandra/tracing/Tracing;
6 16 1 customTracingClass Ljava/lang/String;
11 13 2 e Ljava/lang/Exception;
Exception table:
from to target type
7 9 10 Class java.lang.Exception
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
invokestatic org.apache.cassandra.utils.FBUtilities.getLocalAddress:()Ljava/net/InetAddress;
putfield org.apache.cassandra.tracing.Tracing.localAddress:Ljava/net/InetAddress;
2: aload 0
new io.netty.util.concurrent.FastThreadLocal
dup
invokespecial io.netty.util.concurrent.FastThreadLocal.<init>:()V
putfield org.apache.cassandra.tracing.Tracing.state:Lio/netty/util/concurrent/FastThreadLocal;
3: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield org.apache.cassandra.tracing.Tracing.sessions:Ljava/util/concurrent/ConcurrentMap;
4: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tracing/Tracing;
public java.util.UUID getSessionId();
descriptor: ()Ljava/util/UUID;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.tracing.Tracing.$assertionsDisabled:Z
ifne 1
invokestatic org.apache.cassandra.tracing.Tracing.isTracing:()Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tracing.Tracing.state:Lio/netty/util/concurrent/FastThreadLocal;
invokevirtual io.netty.util.concurrent.FastThreadLocal.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.tracing.TraceState
getfield org.apache.cassandra.tracing.TraceState.sessionId:Ljava/util/UUID;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tracing/Tracing;
public org.apache.cassandra.tracing.Tracing$TraceType getTraceType();
descriptor: ()Lorg/apache/cassandra/tracing/Tracing$TraceType;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.tracing.Tracing.$assertionsDisabled:Z
ifne 1
invokestatic org.apache.cassandra.tracing.Tracing.isTracing:()Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tracing.Tracing.state:Lio/netty/util/concurrent/FastThreadLocal;
invokevirtual io.netty.util.concurrent.FastThreadLocal.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.tracing.TraceState
getfield org.apache.cassandra.tracing.TraceState.traceType:Lorg/apache/cassandra/tracing/Tracing$TraceType;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tracing/Tracing;
public int getTTL();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.tracing.Tracing.$assertionsDisabled:Z
ifne 1
invokestatic org.apache.cassandra.tracing.Tracing.isTracing:()Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tracing.Tracing.state:Lio/netty/util/concurrent/FastThreadLocal;
invokevirtual io.netty.util.concurrent.FastThreadLocal.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.tracing.TraceState
getfield org.apache.cassandra.tracing.TraceState.ttl:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tracing/Tracing;
public static boolean isTracing();
descriptor: ()Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic org.apache.cassandra.tracing.Tracing.instance:Lorg/apache/cassandra/tracing/Tracing;
invokevirtual org.apache.cassandra.tracing.Tracing.get:()Lorg/apache/cassandra/tracing/TraceState;
ifnull 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
LocalVariableTable:
Start End Slot Name Signature
public java.util.UUID newSession(java.util.Map<java.lang.String, java.nio.ByteBuffer>);
descriptor: (Ljava/util/Map;)Ljava/util/UUID;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
1: getstatic org.apache.cassandra.db.marshal.TimeUUIDType.instance:Lorg/apache/cassandra/db/marshal/TimeUUIDType;
invokestatic org.apache.cassandra.utils.UUIDGen.getTimeUUIDBytes:()[B
invokestatic java.nio.ByteBuffer.wrap:([B)Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.marshal.TimeUUIDType.compose:(Ljava/nio/ByteBuffer;)Ljava/lang/Object;
checkcast java.util.UUID
2: getstatic org.apache.cassandra.tracing.Tracing$TraceType.QUERY:Lorg/apache/cassandra/tracing/Tracing$TraceType;
3: aload 1
4: invokevirtual org.apache.cassandra.tracing.Tracing.newSession:(Ljava/util/UUID;Lorg/apache/cassandra/tracing/Tracing$TraceType;Ljava/util/Map;)Ljava/util/UUID;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tracing/Tracing;
0 5 1 customPayload Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;)Ljava/util/UUID;
MethodParameters:
Name Flags
customPayload
public java.util.UUID newSession(org.apache.cassandra.tracing.Tracing$TraceType);
descriptor: (Lorg/apache/cassandra/tracing/Tracing$TraceType;)Ljava/util/UUID;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
1: getstatic org.apache.cassandra.db.marshal.TimeUUIDType.instance:Lorg/apache/cassandra/db/marshal/TimeUUIDType;
invokestatic org.apache.cassandra.utils.UUIDGen.getTimeUUIDBytes:()[B
invokestatic java.nio.ByteBuffer.wrap:([B)Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.marshal.TimeUUIDType.compose:(Ljava/nio/ByteBuffer;)Ljava/lang/Object;
checkcast java.util.UUID
2: aload 1
3: getstatic java.util.Collections.EMPTY_MAP:Ljava/util/Map;
4: invokevirtual org.apache.cassandra.tracing.Tracing.newSession:(Ljava/util/UUID;Lorg/apache/cassandra/tracing/Tracing$TraceType;Ljava/util/Map;)Ljava/util/UUID;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tracing/Tracing;
0 5 1 traceType Lorg/apache/cassandra/tracing/Tracing$TraceType;
MethodParameters:
Name Flags
traceType
public java.util.UUID newSession(java.util.UUID, java.util.Map<java.lang.String, java.nio.ByteBuffer>);
descriptor: (Ljava/util/UUID;Ljava/util/Map;)Ljava/util/UUID;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
getstatic org.apache.cassandra.tracing.Tracing$TraceType.QUERY:Lorg/apache/cassandra/tracing/Tracing$TraceType;
aload 2
invokevirtual org.apache.cassandra.tracing.Tracing.newSession:(Ljava/util/UUID;Lorg/apache/cassandra/tracing/Tracing$TraceType;Ljava/util/Map;)Ljava/util/UUID;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tracing/Tracing;
0 1 1 sessionId Ljava/util/UUID;
0 1 2 customPayload Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
Signature: (Ljava/util/UUID;Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;)Ljava/util/UUID;
MethodParameters:
Name Flags
sessionId
customPayload
protected java.util.UUID newSession(java.util.UUID, org.apache.cassandra.tracing.Tracing$TraceType, java.util.Map<java.lang.String, java.nio.ByteBuffer>);
descriptor: (Ljava/util/UUID;Lorg/apache/cassandra/tracing/Tracing$TraceType;Ljava/util/Map;)Ljava/util/UUID;
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: getstatic org.apache.cassandra.tracing.Tracing.$assertionsDisabled:Z
ifne 1
aload 0
invokevirtual org.apache.cassandra.tracing.Tracing.get:()Lorg/apache/cassandra/tracing/TraceState;
ifnull 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.apache.cassandra.tracing.Tracing.localAddress:Ljava/net/InetAddress;
aload 1
aload 2
invokevirtual org.apache.cassandra.tracing.Tracing.newTraceState:(Ljava/net/InetAddress;Ljava/util/UUID;Lorg/apache/cassandra/tracing/Tracing$TraceType;)Lorg/apache/cassandra/tracing/TraceState;
astore 4
start local 4 2: aload 0
aload 4
invokevirtual org.apache.cassandra.tracing.Tracing.set:(Lorg/apache/cassandra/tracing/TraceState;)V
3: aload 0
getfield org.apache.cassandra.tracing.Tracing.sessions:Ljava/util/concurrent/ConcurrentMap;
aload 1
aload 4
invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 1
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tracing/Tracing;
0 5 1 sessionId Ljava/util/UUID;
0 5 2 traceType Lorg/apache/cassandra/tracing/Tracing$TraceType;
0 5 3 customPayload Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
2 5 4 ts Lorg/apache/cassandra/tracing/TraceState;
Signature: (Ljava/util/UUID;Lorg/apache/cassandra/tracing/Tracing$TraceType;Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;)Ljava/util/UUID;
MethodParameters:
Name Flags
sessionId
traceType
customPayload
public void doneWithNonLocalSession(org.apache.cassandra.tracing.TraceState);
descriptor: (Lorg/apache/cassandra/tracing/TraceState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.tracing.TraceState.releaseReference:()I
ifne 2
1: aload 0
getfield org.apache.cassandra.tracing.Tracing.sessions:Ljava/util/concurrent/ConcurrentMap;
aload 1
getfield org.apache.cassandra.tracing.TraceState.sessionId:Ljava/util/UUID;
invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/tracing/Tracing;
0 3 1 state Lorg/apache/cassandra/tracing/TraceState;
MethodParameters:
Name Flags
state
public void stopSession();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.tracing.Tracing.get:()Lorg/apache/cassandra/tracing/TraceState;
astore 1
start local 1 1: aload 1
ifnonnull 4
2: getstatic org.apache.cassandra.tracing.Tracing.logger:Lorg/slf4j/Logger;
ldc "request complete"
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;)V
3: goto 8
4: StackMap locals: org.apache.cassandra.tracing.TraceState
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.tracing.Tracing.stopSessionImpl:()V
5: aload 1
invokevirtual org.apache.cassandra.tracing.TraceState.stop:()V
6: aload 0
getfield org.apache.cassandra.tracing.Tracing.sessions:Ljava/util/concurrent/ConcurrentMap;
aload 1
getfield org.apache.cassandra.tracing.TraceState.sessionId:Ljava/util/UUID;
invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
7: aload 0
aconst_null
invokevirtual org.apache.cassandra.tracing.Tracing.set:(Lorg/apache/cassandra/tracing/TraceState;)V
8: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/tracing/Tracing;
1 9 1 state Lorg/apache/cassandra/tracing/TraceState;
protected abstract void stopSessionImpl();
descriptor: ()V
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
public org.apache.cassandra.tracing.TraceState get();
descriptor: ()Lorg/apache/cassandra/tracing/TraceState;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tracing.Tracing.state:Lio/netty/util/concurrent/FastThreadLocal;
invokevirtual io.netty.util.concurrent.FastThreadLocal.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.tracing.TraceState
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tracing/Tracing;
public org.apache.cassandra.tracing.TraceState get(java.util.UUID);
descriptor: (Ljava/util/UUID;)Lorg/apache/cassandra/tracing/TraceState;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tracing.Tracing.sessions:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.tracing.TraceState
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tracing/Tracing;
0 1 1 sessionId Ljava/util/UUID;
MethodParameters:
Name Flags
sessionId
public void set(org.apache.cassandra.tracing.TraceState);
descriptor: (Lorg/apache/cassandra/tracing/TraceState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tracing.Tracing.state:Lio/netty/util/concurrent/FastThreadLocal;
aload 1
invokevirtual io.netty.util.concurrent.FastThreadLocal.set:(Ljava/lang/Object;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tracing/Tracing;
0 2 1 tls Lorg/apache/cassandra/tracing/TraceState;
MethodParameters:
Name Flags
tls final
public org.apache.cassandra.tracing.TraceState begin(java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/util/Map;)Lorg/apache/cassandra/tracing/TraceState;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
aload 2
invokevirtual org.apache.cassandra.tracing.Tracing.begin:(Ljava/lang/String;Ljava/net/InetAddress;Ljava/util/Map;)Lorg/apache/cassandra/tracing/TraceState;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tracing/Tracing;
0 1 1 request Ljava/lang/String;
0 1 2 parameters Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lorg/apache/cassandra/tracing/TraceState;
MethodParameters:
Name Flags
request final
parameters final
public abstract org.apache.cassandra.tracing.TraceState begin(java.lang.String, java.net.InetAddress, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/net/InetAddress;Ljava/util/Map;)Lorg/apache/cassandra/tracing/TraceState;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Ljava/lang/String;Ljava/net/InetAddress;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lorg/apache/cassandra/tracing/TraceState;
MethodParameters:
Name Flags
request
client
parameters
public org.apache.cassandra.tracing.TraceState initializeFromMessage(org.apache.cassandra.net.MessageIn<?>);
descriptor: (Lorg/apache/cassandra/net/MessageIn;)Lorg/apache/cassandra/tracing/TraceState;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=7, args_size=2
start local 0 start local 1 0: aload 1
getfield org.apache.cassandra.net.MessageIn.parameters:Ljava/util/Map;
ldc "TraceSession"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast byte[]
astore 2
start local 2 1: aload 2
ifnonnull 3
2: aconst_null
areturn
3: StackMap locals: byte[]
StackMap stack:
getstatic org.apache.cassandra.tracing.Tracing.$assertionsDisabled:Z
ifne 4
aload 2
arraylength
bipush 16
if_icmpeq 4
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
4: StackMap locals:
StackMap stack:
aload 2
invokestatic java.nio.ByteBuffer.wrap:([B)Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.UUIDGen.getUUID:(Ljava/nio/ByteBuffer;)Ljava/util/UUID;
astore 3
start local 3 5: aload 0
aload 3
invokevirtual org.apache.cassandra.tracing.Tracing.get:(Ljava/util/UUID;)Lorg/apache/cassandra/tracing/TraceState;
astore 4
start local 4 6: aload 4
ifnull 8
aload 4
invokevirtual org.apache.cassandra.tracing.TraceState.acquireReference:()Z
ifeq 8
7: aload 4
areturn
8: StackMap locals: java.util.UUID org.apache.cassandra.tracing.TraceState
StackMap stack:
getstatic org.apache.cassandra.tracing.Tracing$TraceType.QUERY:Lorg/apache/cassandra/tracing/Tracing$TraceType;
astore 6
start local 6 9: aload 1
getfield org.apache.cassandra.net.MessageIn.parameters:Ljava/util/Map;
ldc "TraceType"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast byte[]
dup
astore 5
start local 5 10: ifnull 12
11: aload 5
iconst_0
baload
invokestatic org.apache.cassandra.tracing.Tracing$TraceType.deserialize:(B)Lorg/apache/cassandra/tracing/Tracing$TraceType;
astore 6
12: StackMap locals: byte[] org.apache.cassandra.tracing.Tracing$TraceType
StackMap stack:
aload 1
getfield org.apache.cassandra.net.MessageIn.verb:Lorg/apache/cassandra/net/MessagingService$Verb;
getstatic org.apache.cassandra.net.MessagingService$Verb.REQUEST_RESPONSE:Lorg/apache/cassandra/net/MessagingService$Verb;
if_acmpne 14
13: new org.apache.cassandra.tracing.ExpiredTraceState
dup
aload 0
aload 1
getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
aload 3
aload 6
invokevirtual org.apache.cassandra.tracing.Tracing.newTraceState:(Ljava/net/InetAddress;Ljava/util/UUID;Lorg/apache/cassandra/tracing/Tracing$TraceType;)Lorg/apache/cassandra/tracing/TraceState;
invokespecial org.apache.cassandra.tracing.ExpiredTraceState.<init>:(Lorg/apache/cassandra/tracing/TraceState;)V
areturn
14: StackMap locals:
StackMap stack:
aload 0
aload 1
getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
aload 3
aload 6
invokevirtual org.apache.cassandra.tracing.Tracing.newTraceState:(Ljava/net/InetAddress;Ljava/util/UUID;Lorg/apache/cassandra/tracing/Tracing$TraceType;)Lorg/apache/cassandra/tracing/TraceState;
astore 4
15: aload 0
getfield org.apache.cassandra.tracing.Tracing.sessions:Ljava/util/concurrent/ConcurrentMap;
aload 3
aload 4
invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
16: aload 4
areturn
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/apache/cassandra/tracing/Tracing;
0 17 1 message Lorg/apache/cassandra/net/MessageIn<*>;
1 17 2 sessionBytes [B
5 17 3 sessionId Ljava/util/UUID;
6 17 4 ts Lorg/apache/cassandra/tracing/TraceState;
10 17 5 tmpBytes [B
9 17 6 traceType Lorg/apache/cassandra/tracing/Tracing$TraceType;
Signature: (Lorg/apache/cassandra/net/MessageIn<*>;)Lorg/apache/cassandra/tracing/TraceState;
MethodParameters:
Name Flags
message final
public java.util.Map<java.lang.String, byte[]> getTraceHeaders();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.tracing.Tracing.$assertionsDisabled:Z
ifne 1
invokestatic org.apache.cassandra.tracing.Tracing.isTracing:()Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
ldc "TraceSession"
getstatic org.apache.cassandra.tracing.Tracing.instance:Lorg/apache/cassandra/tracing/Tracing;
invokevirtual org.apache.cassandra.tracing.Tracing.getSessionId:()Ljava/util/UUID;
invokestatic org.apache.cassandra.utils.UUIDGen.decompose:(Ljava/util/UUID;)[B
2: ldc "TraceType"
iconst_1
newarray 8
dup
iconst_0
getstatic org.apache.cassandra.tracing.Tracing.instance:Lorg/apache/cassandra/tracing/Tracing;
invokevirtual org.apache.cassandra.tracing.Tracing.getTraceType:()Lorg/apache/cassandra/tracing/Tracing$TraceType;
invokestatic org.apache.cassandra.tracing.Tracing$TraceType.serialize:(Lorg/apache/cassandra/tracing/Tracing$TraceType;)B
bastore
3: invokestatic com.google.common.collect.ImmutableMap.of:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Lcom/google/common/collect/ImmutableMap;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/tracing/Tracing;
Signature: ()Ljava/util/Map<Ljava/lang/String;[B>;
protected abstract org.apache.cassandra.tracing.TraceState newTraceState(java.net.InetAddress, java.util.UUID, org.apache.cassandra.tracing.Tracing$TraceType);
descriptor: (Ljava/net/InetAddress;Ljava/util/UUID;Lorg/apache/cassandra/tracing/Tracing$TraceType;)Lorg/apache/cassandra/tracing/TraceState;
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
MethodParameters:
Name Flags
coordinator
sessionId
traceType
public static void traceRepair(java.lang.String, java.lang.Object[]);
descriptor: (Ljava/lang/String;[Ljava/lang/Object;)V
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.tracing.Tracing.instance:Lorg/apache/cassandra/tracing/Tracing;
invokevirtual org.apache.cassandra.tracing.Tracing.get:()Lorg/apache/cassandra/tracing/TraceState;
astore 2
start local 2 1: aload 2
ifnonnull 3
2: return
3: StackMap locals: org.apache.cassandra.tracing.TraceState
StackMap stack:
aload 2
aload 0
aload 1
invokevirtual org.apache.cassandra.tracing.TraceState.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 format Ljava/lang/String;
0 5 1 args [Ljava/lang/Object;
1 5 2 state Lorg/apache/cassandra/tracing/TraceState;
MethodParameters:
Name Flags
format
args
public static void trace(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: getstatic org.apache.cassandra.tracing.Tracing.instance:Lorg/apache/cassandra/tracing/Tracing;
invokevirtual org.apache.cassandra.tracing.Tracing.get:()Lorg/apache/cassandra/tracing/TraceState;
astore 1
start local 1 1: aload 1
ifnonnull 3
2: return
3: StackMap locals: org.apache.cassandra.tracing.TraceState
StackMap stack:
aload 1
aload 0
invokevirtual org.apache.cassandra.tracing.TraceState.trace:(Ljava/lang/String;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 message Ljava/lang/String;
1 5 1 state Lorg/apache/cassandra/tracing/TraceState;
MethodParameters:
Name Flags
message
public static void trace(java.lang.String, java.lang.Object);
descriptor: (Ljava/lang/String;Ljava/lang/Object;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.tracing.Tracing.instance:Lorg/apache/cassandra/tracing/Tracing;
invokevirtual org.apache.cassandra.tracing.Tracing.get:()Lorg/apache/cassandra/tracing/TraceState;
astore 2
start local 2 1: aload 2
ifnonnull 3
2: return
3: StackMap locals: org.apache.cassandra.tracing.TraceState
StackMap stack:
aload 2
aload 0
aload 1
invokevirtual org.apache.cassandra.tracing.TraceState.trace:(Ljava/lang/String;Ljava/lang/Object;)V
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 format Ljava/lang/String;
0 5 1 arg Ljava/lang/Object;
1 5 2 state Lorg/apache/cassandra/tracing/TraceState;
MethodParameters:
Name Flags
format
arg
public static void trace(java.lang.String, java.lang.Object, java.lang.Object);
descriptor: (Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.tracing.Tracing.instance:Lorg/apache/cassandra/tracing/Tracing;
invokevirtual org.apache.cassandra.tracing.Tracing.get:()Lorg/apache/cassandra/tracing/TraceState;
astore 3
start local 3 1: aload 3
ifnonnull 3
2: return
3: StackMap locals: org.apache.cassandra.tracing.TraceState
StackMap stack:
aload 3
aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.tracing.TraceState.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
4: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 format Ljava/lang/String;
0 5 1 arg1 Ljava/lang/Object;
0 5 2 arg2 Ljava/lang/Object;
1 5 3 state Lorg/apache/cassandra/tracing/TraceState;
MethodParameters:
Name Flags
format
arg1
arg2
public static void trace(java.lang.String, java.lang.Object[]);
descriptor: (Ljava/lang/String;[Ljava/lang/Object;)V
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.tracing.Tracing.instance:Lorg/apache/cassandra/tracing/Tracing;
invokevirtual org.apache.cassandra.tracing.Tracing.get:()Lorg/apache/cassandra/tracing/TraceState;
astore 2
start local 2 1: aload 2
ifnonnull 3
2: return
3: StackMap locals: org.apache.cassandra.tracing.TraceState
StackMap stack:
aload 2
aload 0
aload 1
invokevirtual org.apache.cassandra.tracing.TraceState.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 format Ljava/lang/String;
0 5 1 args [Ljava/lang/Object;
1 5 2 state Lorg/apache/cassandra/tracing/TraceState;
MethodParameters:
Name Flags
format
args
public abstract void trace(java.nio.ByteBuffer, java.lang.String, int);
descriptor: (Ljava/nio/ByteBuffer;Ljava/lang/String;I)V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
MethodParameters:
Name Flags
sessionId
message
ttl
public void set(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast org.apache.cassandra.tracing.TraceState
invokevirtual org.apache.cassandra.tracing.Tracing.set:(Lorg/apache/cassandra/tracing/TraceState;)V
return
LocalVariableTable:
Start End Slot Name Signature
public java.lang.Object get();
descriptor: ()Ljava/lang/Object;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual org.apache.cassandra.tracing.Tracing.get:()Lorg/apache/cassandra/tracing/TraceState;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: Ljava/lang/Object;Lorg/apache/cassandra/concurrent/ExecutorLocal<Lorg/apache/cassandra/tracing/TraceState;>;
SourceFile: "Tracing.java"
NestMembers:
org.apache.cassandra.tracing.Tracing$TraceType
InnerClasses:
public Verb = org.apache.cassandra.net.MessagingService$Verb of org.apache.cassandra.net.MessagingService
public final TraceType = org.apache.cassandra.tracing.Tracing$TraceType of org.apache.cassandra.tracing.Tracing