Class AbstractTraceProcessingStage<T>
java.lang.Object
teetime.framework.AbstractStage
teetime.framework.AbstractConsumerStage<T>
kieker.analysis.architecture.trace.AbstractTraceAnalysisStage<T>
kieker.analysis.architecture.trace.AbstractTraceProcessingStage<T>
- Type Parameters:
T
- an AbstractTrace type
- Direct Known Subclasses:
AbstractExecutionTraceProcessingFilter
,AbstractMessageTraceProcessingFilter
,ExecutionTraceWriterFilter
,InvalidExecutionTraceWriterSink
,MessageTraceWriterFilter
,TraceEquivalenceClassFilter
,TraceEventRecords2ExecutionAndMessageTraceStage
,TraceReconstructionStage
public abstract class AbstractTraceProcessingStage<T> extends AbstractTraceAnalysisStage<T>
This is an abstract base for filters processing traces.
- Since:
- 1.1
- Author:
- Andre van Hoorn, Reiner Jung -- ported to TeeTime
-
Field Summary
-
Constructor Summary
Constructors Constructor Description AbstractTraceProcessingStage(SystemModelRepository systemModelRepository)
Creates a new instance of this class using the given parameters. -
Method Summary
Modifier and Type Method Description int
getErrorCount()
Delivers the number of traces which have not been processed successfully.long
getLastTraceIdError()
Delivers the ID of the last trace which has not been processed successfully.long
getLastTraceIdSuccess()
Delivers the ID of the last trace which has been processed successfully.int
getSuccessCount()
Delivers the number of traces which have been processed successfully.int
getTotalCount()
Delivers the total number of traces which have been processed.void
printStatusMessage()
Returns a user-addressed status message to be logged by the calling tool.protected void
reportError(long traceId)
This method can be used to report a trace which has not been processed successfully.protected void
reportSuccess(long traceId)
This method can be used to report a trace which has been processed successfully.Methods inherited from class kieker.analysis.architecture.trace.AbstractTraceAnalysisStage
createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, getSystemModelRepository, printDebugLogMessage, printErrorLogMessage
Methods inherited from class teetime.framework.AbstractConsumerStage
createInputPort, execute, execute, getInputPort
Methods inherited from class teetime.framework.AbstractStage
abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
-
Constructor Details
-
AbstractTraceProcessingStage
Creates a new instance of this class using the given parameters.- Parameters:
systemModelRepository
- the model repository to be used
-
-
Method Details
-
reportSuccess
protected final void reportSuccess(long traceId)This method can be used to report a trace which has been processed successfully.- Parameters:
traceId
- The ID of the processed trace.
-
reportError
protected final void reportError(long traceId)This method can be used to report a trace which has not been processed successfully.- Parameters:
traceId
- The ID of the processed trace.
-
getSuccessCount
public final int getSuccessCount()Delivers the number of traces which have been processed successfully.- Returns:
- The number of traces.
-
getErrorCount
public final int getErrorCount()Delivers the number of traces which have not been processed successfully.- Returns:
- The number of traces.
-
getTotalCount
public final int getTotalCount()Delivers the total number of traces which have been processed.- Returns:
- The number of traces.
-
getLastTraceIdError
public final long getLastTraceIdError()Delivers the ID of the last trace which has not been processed successfully.- Returns:
- The trace ID.
-
getLastTraceIdSuccess
public final long getLastTraceIdSuccess()Delivers the ID of the last trace which has been processed successfully.- Returns:
- The trace ID.
-
printStatusMessage
public void printStatusMessage()Returns a user-addressed status message to be logged by the calling tool. Extending classes may override this method but should call the then-inherited method first.
-