kieker.tools.traceAnalysis.filter.traceReconstruction
Class TraceReconstructionFilter

java.lang.Object
  kieker.analysis.plugin.AbstractPlugin
      kieker.analysis.plugin.filter.AbstractFilterPlugin
          kieker.tools.traceAnalysis.filter.AbstractTraceAnalysisFilter
              kieker.tools.traceAnalysis.filter.AbstractTraceProcessingFilter
                  kieker.tools.traceAnalysis.filter.traceReconstruction.TraceReconstructionFilter

All Implemented Interfaces:

IFilterPlugin, IPlugin

public class TraceReconstructionFilter
extends AbstractTraceProcessingFilter

Author:

Andre van Hoorn

Nested Class Summary

Nested classes/interfaces inherited from interface kieker.analysis.plugin.IPlugin

IPlugin.PluginInputPortReference

Field Summary

static String	CONFIG_PROPERTY_NAME_IGNORE_INVALID_TRACES
static String	CONFIG_PROPERTY_NAME_MAX_TRACE_DURATION_MILLIS
static String	INPUT_PORT_NAME_EXECUTIONS
static String	OUTPUT_PORT_NAME_EXECUTION_TRACE
static String	OUTPUT_PORT_NAME_INVALID_EXECUTION_TRACE
static String	OUTPUT_PORT_NAME_MESSAGE_TRACE

Fields inherited from class kieker.tools.traceAnalysis.filter.AbstractTraceProcessingFilter

MAX_DURATION_MILLIS

Fields inherited from class kieker.tools.traceAnalysis.filter.AbstractTraceAnalysisFilter

REPOSITORY_PORT_NAME_SYSTEM_MODEL

Fields inherited from class kieker.analysis.plugin.AbstractPlugin

CONFIG_NAME

Constructor Summary

TraceReconstructionFilter(Configuration configuration)

Method Summary

Configuration	getCurrentConfiguration() This method should deliver a Configuration object containing the current configuration of this instance.
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
long	getMinTin() Returns the minimum tin timestamp of a processed execution.
boolean	init() Initiates the start of a component.
void	inputExecutions(Execution execution)
void	printStatusMessage() Returns a user-addressed status message to be logged by the calling tool.
void	terminate(boolean error) Terminates the filter (internally, all pending traces are processed).

Methods inherited from class kieker.tools.traceAnalysis.filter.AbstractTraceProcessingFilter

getErrorCount, getLastTraceIdError, getLastTraceIdSuccess, getSuccessCount, getTotalCount

Methods inherited from class kieker.tools.traceAnalysis.filter.AbstractTraceAnalysisFilter

createExecutionByEntityNames, setErrStream, setOutStream

Methods inherited from class kieker.analysis.plugin.AbstractPlugin

areAllRepositoryPortsConnected, connect, connect, getAllInputPortNames, getAllOutputPortNames, getConnectedPlugins, getCurrentRepositories, getName, getPluginDescription, getPluginName, isConnectionAllowed

Methods inherited from class java.lang.Object

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

Field Detail

INPUT_PORT_NAME_EXECUTIONS

public static final String INPUT_PORT_NAME_EXECUTIONS

See Also:

Constant Field Values

OUTPUT_PORT_NAME_MESSAGE_TRACE

public static final String OUTPUT_PORT_NAME_MESSAGE_TRACE

See Also:

Constant Field Values

OUTPUT_PORT_NAME_EXECUTION_TRACE

public static final String OUTPUT_PORT_NAME_EXECUTION_TRACE

See Also:

Constant Field Values

OUTPUT_PORT_NAME_INVALID_EXECUTION_TRACE

public static final String OUTPUT_PORT_NAME_INVALID_EXECUTION_TRACE

See Also:

Constant Field Values

CONFIG_PROPERTY_NAME_MAX_TRACE_DURATION_MILLIS

public static final String CONFIG_PROPERTY_NAME_MAX_TRACE_DURATION_MILLIS

See Also:

Constant Field Values

CONFIG_PROPERTY_NAME_IGNORE_INVALID_TRACES

public static final String CONFIG_PROPERTY_NAME_IGNORE_INVALID_TRACES

See Also:

Constant Field Values

Constructor Detail

TraceReconstructionFilter

public TraceReconstructionFilter(Configuration configuration)

Method Detail

getInvalidTraces

public Set<Long> getInvalidTraces()

Returns a set of the IDs of invalid traces.

Returns:

a set of the IDs of invalid traces

getMinTin

public final long getMinTin()

Returns the minimum tin timestamp of a processed execution.

Returns:

the minimum tin timestamp of a processed execution

getMaxTout

public final long getMaxTout()

Returns the maximum tout timestamp of a processed execution.

Returns:

the maximum tout timestamp of a processed execution

init

public boolean init()

Description copied from interface: IFilterPlugin

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

Specified by:

init in interface IFilterPlugin

Overrides:

init in class AbstractFilterPlugin

Returns:

true on success; false otherwise.

inputExecutions

public void inputExecutions(Execution execution)

getMaxTraceDurationNanos

public final long getMaxTraceDurationNanos()

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

Returns:

the timeout duration for a pending trace in nanoseconds

terminate

public void terminate(boolean error)

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

Specified by:

terminate in interface IFilterPlugin

Overrides:

terminate in class AbstractFilterPlugin

Parameters:

error -

printStatusMessage

public void printStatusMessage()

Description copied from class: AbstractTraceProcessingFilter

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.

Overrides:

printStatusMessage in class AbstractTraceProcessingFilter

getCurrentConfiguration

public Configuration getCurrentConfiguration()

Description copied from interface: IPlugin

This method should deliver a Configuration object containing the current configuration of this instance. In other words: The constructor should be able to use the given object to initialize a new instance of this class with the same intern properties.

Returns:

A completely filled configuration object.