Package org.apache.cassandra.tracing

Class Tracing

java.lang.Object

org.apache.cassandra.concurrent.ExecutorLocals.Impl

org.apache.cassandra.tracing.Tracing

public abstract class Tracing
extends ExecutorLocals.Impl

A trace session context. Able to track and store trace sessions. A session is usually a user initiated query, and may have multiple local and remote events before it is completed.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	Tracing.TraceType

Field Summary

Fields

Modifier and Type	Field	Description
static final Tracing	instance
protected static final org.slf4j.Logger	logger
protected final ConcurrentMap<TimeUUID,TraceState>	sessions
static final IVersionedSerializer<Tracing.TraceType>	traceTypeSerializer

Constructor Summary

Constructors

Constructor	Description
Tracing()

Method Summary

Modifier and Type	Method	Description
Map<ParamType,Object>	addTraceHeaders(Map<ParamType,Object> addToMutable)
abstract TraceState	begin(String request, InetAddress client, Map<String,String> parameters)
TraceState	begin(String request, Map<String,String> parameters)
void	doneWithNonLocalSession(TraceState state)
TraceState	get()
TraceState	get(TimeUUID sessionId)
TimeUUID	getSessionId()
Tracing.TraceType	getTraceType()
int	getTTL()
TraceState	initializeFromMessage(Message.Header header)	Determines the tracing context from a message.
static boolean	isTracing()	Indicates if the current thread's execution is being traced.
TimeUUID	newSession(Map<String,ByteBuffer> customPayload)
TimeUUID	newSession(Tracing.TraceType traceType)
TimeUUID	newSession(TimeUUID sessionId, Map<String,ByteBuffer> customPayload)
protected TimeUUID	newSession(TimeUUID sessionId, Tracing.TraceType traceType, Map<String,ByteBuffer> customPayload)	This method is intended to be overridden in tracing implementations that need access to the customPayload
protected abstract TraceState	newTraceState(InetAddressAndPort coordinator, TimeUUID sessionId, Tracing.TraceType traceType)
void	set(TraceState tls)
void	stopSession()	Stop the session and record its complete.
protected abstract void	stopSessionImpl()
static void	trace(String message)
static void	trace(String format, Object arg)
static void	trace(String format, Object... args)
static void	trace(String format, Object arg1, Object arg2)
abstract void	trace(ByteBuffer sessionId, String message, int ttl)	Called for non-local traces (traces that are not initiated by local node == coordinator).
void	traceOutgoingMessage(Message<?> message, int serializedSize, InetAddressAndPort sendTo)	Record any tracing data, if enabled on this message.
static void	traceRepair(String format, Object... args)

Methods inherited from class org.apache.cassandra.concurrent.ExecutorLocals.Impl

set

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

traceTypeSerializer

public static final IVersionedSerializer<Tracing.TraceType> traceTypeSerializer

logger

protected static final org.slf4j.Logger logger

sessions

protected final ConcurrentMap<TimeUUID,TraceState> sessions

instance

public static final Tracing instance

Constructor Details

Tracing

public Tracing()

Method Details

getSessionId

public TimeUUID getSessionId()

getTraceType

public Tracing.TraceType getTraceType()

getTTL

public int getTTL()

isTracing

public static boolean isTracing()

Indicates if the current thread's execution is being traced.

newSession

public TimeUUID newSession(Map<String,ByteBuffer> customPayload)

newSession

public TimeUUID newSession(Tracing.TraceType traceType)

newSession

public TimeUUID newSession(TimeUUID sessionId,
 Map<String,ByteBuffer> customPayload)

newSession

protected TimeUUID newSession(TimeUUID sessionId,
 Tracing.TraceType traceType,
 Map<String,ByteBuffer> customPayload)

This method is intended to be overridden in tracing implementations that need access to the customPayload

doneWithNonLocalSession

public void doneWithNonLocalSession(TraceState state)

stopSession

public void stopSession()

Stop the session and record its complete. Called by coodinator when request is complete.

stopSessionImpl

protected abstract void stopSessionImpl()

get

public TraceState get()

get

public TraceState get(TimeUUID sessionId)

set

public void set(TraceState tls)

begin

public TraceState begin(String request,
 Map<String,String> parameters)

begin

public abstract TraceState begin(String request,
 InetAddress client,
 Map<String,String> parameters)

initializeFromMessage

public TraceState initializeFromMessage(Message.Header header)

Determines the tracing context from a message. Does NOT set the threadlocal state.

Parameters:

header - The internode message header

traceOutgoingMessage

public void traceOutgoingMessage(Message<?> message,
 int serializedSize,
 InetAddressAndPort sendTo)

Record any tracing data, if enabled on this message.

addTraceHeaders

public Map<ParamType,Object> addTraceHeaders(Map<ParamType,Object> addToMutable)

newTraceState

protected abstract TraceState newTraceState(InetAddressAndPort coordinator,
 TimeUUID sessionId,
 Tracing.TraceType traceType)

traceRepair

public static void traceRepair(String format,
 Object... args)

trace

public static void trace(String message)

trace

public static void trace(String format,
 Object arg)

trace

public static void trace(String format,
 Object arg1,
 Object arg2)

trace

public static void trace(String format,
 Object... args)

trace

public abstract void trace(ByteBuffer sessionId,
 String message,
 int ttl)

Called for non-local traces (traces that are not initiated by local node == coordinator).