kieker.tools.traceAnalysis.plugins.traceReconstruction
Class TraceReconstructionFilter

java.lang.Object
  kieker.tools.traceAnalysis.plugins.AbstractTraceAnalysisPlugin
      kieker.tools.traceAnalysis.plugins.AbstractTraceProcessingPlugin
          kieker.tools.traceAnalysis.plugins.traceReconstruction.TraceReconstructionFilter

All Implemented Interfaces:

IAnalysisPlugin

public class TraceReconstructionFilter
extends AbstractTraceProcessingPlugin

Author:

Andre van Hoorn

Field Summary

static int

MAX_DURATION_MILLIS

Constructor Summary

TraceReconstructionFilter(String name, SystemModelRepository systemEntityFactory, long maxTraceDurationMillis, boolean ignoreInvalidTraces)

Method Summary

boolean	execute() Initiates the start of a component.
IInputPort<Execution>	getExecutionInputPort()
IOutputPort<ExecutionTrace>	getExecutionTraceOutputPort()
IOutputPort<InvalidExecutionTrace>	getInvalidExecutionTraceOutputPort()
Set<Long>	getInvalidTraces() Returns a set of the IDs of invalid traces.
long	getMaxTout() Returns the maximum tout timestamp of a processed execution.
long	getMaxTraceDurationNanos() Return the number of nanoseconds after which a pending trace is considered to have timed out
IOutputPort<MessageTrace>	getMessageTraceOutputPort()
long	getMinTin() Returns the minimum tin timestamp of a processed execution.
void	printStatusMessage()
void	terminate(boolean error) Terminates the filter (internally, all pending traces are processed).

Methods inherited from class kieker.tools.traceAnalysis.plugins.AbstractTraceProcessingPlugin

getErrorCount, getLastTraceIdError, getLastTraceIdSuccess, getSuccessCount, getTotalCount

Methods inherited from class java.lang.Object

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

Field Detail

MAX_DURATION_MILLIS

public static final int MAX_DURATION_MILLIS

See Also:

Constant Field Values

Constructor Detail

TraceReconstructionFilter

public TraceReconstructionFilter(String name,
                                 SystemModelRepository systemEntityFactory,
                                 long maxTraceDurationMillis,
                                 boolean ignoreInvalidTraces)

Method Detail

getInvalidTraces

public Set<Long> getInvalidTraces()

Returns a set of the IDs of invalid traces.

Returns:

getMinTin

public final long getMinTin()

Returns the minimum tin timestamp of a processed execution.

Returns:

getMaxTout

public final long getMaxTout()

Returns the maximum tout timestamp of a processed execution.

Returns:

execute

public boolean execute()

Description copied from interface: IAnalysisPlugin

Initiates the start of a component. This method is called once when a TpanInstance's run() method is called. This implementation must not be blocking! Asynchronous consumers would spawn (an) aynchronous thread(s) in this method.

Returns:

true on success; false otherwise.

getMaxTraceDurationNanos

public final long getMaxTraceDurationNanos()

Return the number of nanoseconds after which a pending trace is considered to have timed out

Returns:

terminate

public void terminate(boolean error)

Terminates the filter (internally, all pending traces are processed).

Parameters:

error -

printStatusMessage

public void printStatusMessage()

Overrides:

printStatusMessage in class AbstractTraceProcessingPlugin

getExecutionInputPort

public IInputPort<Execution> getExecutionInputPort()

getMessageTraceOutputPort

public IOutputPort<MessageTrace> getMessageTraceOutputPort()

getExecutionTraceOutputPort

public IOutputPort<ExecutionTrace> getExecutionTraceOutputPort()

getInvalidExecutionTraceOutputPort

public IOutputPort<InvalidExecutionTrace> getInvalidExecutionTraceOutputPort()