org.apache.cassandra.tracing

Class TraceStateImpl

java.lang.Object

org.apache.cassandra.tracing.TraceState

org.apache.cassandra.tracing.TraceStateImpl

All Implemented Interfaces:

ProgressEventNotifier

public class TraceStateImpl
extends TraceState

ThreadLocal state for a tracing session. The presence of an instance of this class as a ThreadLocal denotes that an operation is being traced.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.tracing.TraceState

TraceState.Status

Field Summary

Fields inherited from class org.apache.cassandra.tracing.TraceState

coordinator, sessionId, sessionIdBytes, traceType, ttl, watch

Constructor Summary

Constructors

Constructor and Description
TraceStateImpl(java.net.InetAddress coordinator, java.util.UUID sessionId, Tracing.TraceType traceType)

Method Summary

Modifier and Type	Method and Description
protected void	traceImpl(java.lang.String message)
protected void	waitForPendingEvents() Post a no-op event to the TRACING stage, so that we can be sure that any previous mutations have at least been applied to one replica.

Methods inherited from class org.apache.cassandra.tracing.TraceState

acquireReference, addProgressListener, elapsed, enableActivityNotification, notifyActivity, releaseReference, removeProgressListener, stop, trace, trace, trace, trace, waitActivity

Methods inherited from class java.lang.Object

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

Constructor Detail

TraceStateImpl

public TraceStateImpl(java.net.InetAddress coordinator,
                      java.util.UUID sessionId,
                      Tracing.TraceType traceType)

Method Detail

traceImpl

protected void traceImpl(java.lang.String message)

Specified by:

traceImpl in class TraceState

waitForPendingEvents

protected void waitForPendingEvents()

Post a no-op event to the TRACING stage, so that we can be sure that any previous mutations have at least been applied to one replica. This works because the tracking executor only has one thread in its pool, see StageManager.tracingExecutor().

Specified by:

waitForPendingEvents in class TraceState