Kieker 1.2

kieker.tools.traceAnalysis.plugins.traceReconstruction
Class TraceReconstructionFilter

java.lang.Object
  extended by kieker.tools.traceAnalysis.plugins.AbstractTraceAnalysisPlugin
      extended by kieker.tools.traceAnalysis.plugins.AbstractTraceProcessingPlugin
          extended by 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()

Kieker 1.2

Copyright 2010 the Kieker Project, http://kieker.sourceforge.net