public class TraceReconstructionStage extends AbstractTraceProcessingStage<Execution>
Constructor and Description |
---|
TraceReconstructionStage(SystemModelRepository repository,
java.util.concurrent.TimeUnit timeunit,
boolean ignoreInvalidTraces,
java.lang.Long maxTraceDuration)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute(Execution execution) |
teetime.framework.OutputPort<ExecutionTrace> |
getExecutionTraceOutputPort() |
teetime.framework.OutputPort<InvalidExecutionTrace> |
getInvalidExecutionTraceOutputPort() |
java.util.Set<java.lang.Long> |
getInvalidTraces()
Returns a set of the IDs of invalid traces.
|
long |
getMaxTout()
Returns the maximum tout timestamp of a processed execution.
|
long |
getMaxTraceDuration()
Return the number of timeunits after which a pending trace is considered to
have timed out.
|
teetime.framework.OutputPort<MessageTrace> |
getMessageTraceOutputPort() |
long |
getMinTin()
Returns the minimum tin timestamp of a processed execution.
|
protected void |
onTerminating() |
void |
printStatusMessage()
Returns a user-addressed status message to be logged by the calling tool.
|
getErrorCount, getLastTraceIdError, getLastTraceIdSuccess, getSuccessCount, getTotalCount, reportError, reportSuccess
createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, getSystemModelRepository, printDebugLogMessage, printErrorLogMessage
createInputPort, execute, getInputPort
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, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
public TraceReconstructionStage(SystemModelRepository repository, java.util.concurrent.TimeUnit timeunit, boolean ignoreInvalidTraces, java.lang.Long maxTraceDuration)
repository
- the system model repositorytimeunit
- the used time unit, e.g., NANOSECONDSignoreInvalidTraces
- set whether invalid traces should be ignored
(true), or the filter must terminate (false)maxTraceDuration
- max time duration for a trace, if null
Long.MAX_VALUEpublic java.util.Set<java.lang.Long> getInvalidTraces()
public final long getMinTin()
public final long getMaxTout()
protected void execute(Execution execution) throws java.lang.Exception
execute
in class teetime.framework.AbstractConsumerStage<Execution>
java.lang.Exception
public final long getMaxTraceDuration()
protected void onTerminating()
onTerminating
in class teetime.framework.AbstractStage
public void printStatusMessage()
AbstractTraceProcessingStage
printStatusMessage
in class AbstractTraceProcessingStage<Execution>
public teetime.framework.OutputPort<MessageTrace> getMessageTraceOutputPort()
public teetime.framework.OutputPort<ExecutionTrace> getExecutionTraceOutputPort()
public teetime.framework.OutputPort<InvalidExecutionTrace> getInvalidExecutionTraceOutputPort()
Copyright 2021 Kieker Project, http://kieker-monitoring.net